Golang中的并发处理

最近发现不少小伙伴都对Golang很感兴趣，所以今天继续给大家介绍Golang相关的知识，本文《Golang中的并发处理》主要内容涉及到等等知识点，希望能帮到你！当然如果阅读本文时存在不同想法，可以在评论中表达，但是请勿使用过激的措辞~

我想实现我的程序来处理批处理，这可以提高流程的效率。

如果我设置一个函数等待几秒钟然后处理从客户端收到的所有消息，我很困惑，如何才能在不中断不定式循环的情况下做到这一点。例如

for{
    msg <- listenUDP
    batching(msg)
}

而且，当收到新的“msg”并且批处理函数仍在运行时，我不确定是否使批处理函数可以等待而不中断 for 循环。系统会调用新的批处理函数吗？如果这样做，如何强制系统使用现有的批处理函数而不是调用新的批处理函数？

正确答案

根据您提供的详细信息，一种可能的方法是您可以维护内存中尚未处理的事件列表，然后在指定时间后或列表达到指定时间后调用单独的 goroutine 来处理每个批次。具体尺寸。

这样，当您批量处理消息时，您的无限循环可以继续处理消息。根据需求，您可以在主 goroutine 和批处理 goroutine 之间进行通信

这取决于实际的实现。例如，您可以生成一个工作线程，然后忘记它，即主 goroutine 只是继续接收消息。其伪代码可能如下所示：

for each event received:
    check if the time limit has crossed or if the message list has crossed
    if yes then spawn a new goroutine and forget about it
    if not push the message to list and continue to the next message

到这里，我们也就讲完了《Golang中的并发处理》的内容了。个人认为，基础知识的学习和巩固，是为了更好的将其运用到项目中，欢迎关注golang学习网公众号，带你了解更多关于的知识点！