选择哪种并发模式适用于以下用例？

怎么入门Golang编程？需要学习哪些知识点？这是新手们刚接触编程时常见的问题；下面golang学习网就来给大家整理分享一些知识点，希望能够给初学者一些帮助。本篇文章就来介绍《选择哪种并发模式适用于以下用例？》，涉及到，有需要的可以收藏一下

我有两个 go 例程 。

• NewFileEntryCheck()
• UploadFromQueueToCloud()

go NewFileEntryCheck()

此函数将采用 fsnotify.Watcher() 作为参数，它将在无限循环内监视指定目录中的任何文件更改。

如果有任何新的file CREATE事件发生，它会将文件名添加到Queue

go UploadFromQueueToCloud()

这个 go 例程应该从 Queue 中获取文件名，从路径中读取文件并将其上传到云端。

现在，我的问题是，如何使 UploadFromQueueToCloud() 函数从队列中获取值并将其上传到云端？

由于NewFileEntryCheck()函数会不断检查新文件并将其添加到队列中，因此Queue的长度不固定。我无法循环遍历 len(Queue) 并通过通道接收数据。

还有其他方法可以实现这一目标吗？

正确答案

这只是发布-订阅模型的一个常见示例。您有一名发布者 (newfileentrycheck) 和一名订阅者 (uploadfromqueuetocloud)。因为这可以以 pub-sub 模型的形式建模，所以您应该进行类似的设计。

您可能已经从 @jimb 收到一条评论，询问 queue 是否是一个通道。这是有原因的。这是因为 golang 通道的行为就像队列一样。因此，一种解决方案肯定是使用通道对其进行建模。

使用通道，您可以将任务/文件名从一个 go 例程中放入。从另一个 go 例程 uploadfromqueuetocloud 中，您可以使用该通道并异步处理数据。

这是示例代码

func UploadFromQueueToCloud(channel *chan string, exit *chan bool) {
    for {
        select {
           case file := <- channel:
               // Upload the cloud..
               // Other business logics
           case exit := <- exit:
               break;
        }
    }
}

func NewFileEntryCheck(notifier *fsnotify.Watcher) {
   channel := make(chan string)
   exit := make(chan bool)
   for {
        if (some breaking condition) {
             exit <- true;
             break;
        }
        // Check for the file notifier
        // If file CREATE happened,
        // get the file name into FileName
        channel <- FileName;
        go UploadFromQueueToCloud(channel, exit)
   }
}

注意：您可以通过将通道更改为缓冲通道来提高吞吐量。

希望有帮助。

文中关于的知识介绍，希望对你的学习有所帮助！若是受益匪浅，那就动动鼠标收藏这篇《选择哪种并发模式适用于以下用例？》文章吧，也可关注golang学习网公众号了解相关技术文章。