我想實現我的程序來處理批處理,這可以提高流程的效率。我感到困惑的是,如果我設置一個函數等待幾秒鐘,然后處理從客戶端收到的所有消息,我怎么能做到這一點而不中斷不定式循環(huán)。例如:for{
msg <- listenUDP
batching(msg)
}而且我也不確定我是否使批處理功能可以在不中斷for循環(huán)的情況下等待,當收到新的“msg”并且批處理功能仍在運行時。系統是否會調用新的批處理函數?如果這樣做,我如何強制系統使用現有的批處理函數,而不是調用新的批處理函數?
在 golang 中配料
慕田峪7331174
2022-08-24 16:15:15