登录
首页 >  Golang >  Go问答

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

来源:stackoverflow

时间:2024-03-06 10:30:29 458浏览 收藏

怎么入门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学习网公众号了解相关技术文章。

声明:本文转载于:stackoverflow 如有侵犯,请联系study_golang@163.com删除
相关阅读
更多>
最新阅读
更多>
课程推荐
更多>