为什么在这个函数中使用通道？

哈喽！大家好，很高兴又见面了，我是golang学习网的一名作者，今天由我给大家带来一篇《为什么在这个函数中使用通道？》，本文主要会讲到等等知识点，希望大家一起学习进步，也欢迎大家关注、点赞、收藏、转发! 下面就一起来看看吧！

我正在研究一篇关于使用 go-routines 的时机的博客，我看到了下面粘贴的示例，从第 61 行到第 65 行。但我不明白这里使用通道的目的。

他似乎正在迭代通道以检索 go-routine 内的消息。 但为什么不直接使用字符串数组呢？

58 func findConcurrent(goroutines int, topic string, docs []string) int {
59     var found int64
60
61     ch := make(chan string, len(docs))
62     for _, doc := range docs {
63         ch <- doc
64     }
65     close(ch)
66
67     var wg sync.WaitGroup
68     wg.Add(goroutines)
69
70     for g := 0; g < goroutines; g++ {
71         go func() {
72             var lFound int64
73             for doc := range ch {
74                 items, err := read(doc)
75                 if err != nil {
76                     continue
77                 }
78                 for _, item := range items {
79                     if strings.Contains(item.Description, topic) {
80                         lFound++
81                     }
82                 }
83             }
84             atomic.AddInt64(&found, lFound)
85             wg.Done()
86         }()
87     }
88
89     wg.Wait()
90
91     return int(found)
92 }

解决方案

此代码提供了在多个 goroutines 之间分配工作（在文档中查找字符串）的示例。基本上，代码是启动 goroutines 并向它们提供文档以通过通道进行搜索。

但是为什么不直接使用字符串数组呢？

可以使用字符串数组和变量（我们称之为 count）来跟踪您正在处理的数组中的项目。您将有一些类似的代码（有点啰嗦来演示一点）：

for {
   if count > len(docarray) {
      break;
   }
   doc := docarray[count]
   count++
   // Process the document
}

但是您会遇到同步问题。例如，如果两个 go 例程（在不同的处理器内核上运行）同时到达 if count > len(docarray) 会发生什么？如果没有某些措施来防止这种情况，它们最终可能都会处理切片中的相同项目（并且可能会跳过下一个元素，因为它们都运行 count++）。

进程同步很复杂，而且问题可能很难调试。使用通道可以隐藏很多复杂性，并使您的代码更有可能按预期工作（它不能解决所有问题；请注意在示例代码中使用 atomic.addint64(&found, lfound) 来防止另一个问题多个 go 例程同时写入变量可能会导致潜在的问题）。

作者似乎只是使用一个人为的示例来说明通道是如何工作的。也许他需要想出一个更现实的例子。但他确实说：

因此，很明显他并不是想为这项工作编写最好的代码，只是为了说明他的观点。

今天带大家了解了的相关知识，希望对你有所帮助；关于Golang的技术知识我们会一点点深入介绍，欢迎大家关注golang学习网公众号，一起学习编程~