如何正确关闭通道？

huangapple
go评论139阅读模式
英文:

How do I close the channel correctly?

问题

据我理解，死锁出现的原因是通道没有关闭。如何关闭通道以解决死锁问题？

我使用这个库来限制 goroutine 的数量：https://github.com/zenthangplus/goccm

代码：

  1. func main() {
  2.    c := goccm.New(5)
  3.    chanStr := make(chan string)
  4.    lines := []string{"aaaaaa", "fffff", "ddddd", "eeeee"}
  6.    for _, value := range lines {
  7.       value := value
  8.       c.Wait()
  9.       go func() {
  10.          chanStr <- value
  11.          c.Done()
  12.       }()
  13.    }
  15.    for value := range chanStr {
  16.       fmt.Println(value)
  17.    }
  18.    c.WaitAllDone()
  20. }

在此之前，我使用通道 done 来判断所有 goroutine 是否完成，并关闭通道，但在此之前我没有限制 goroutine 的数量。

英文:

As far as I understand the deadlock appears because the channel is not closed. How do I close the channel to get rid of the deadlock?

I use this library to limit the number of goroutines: https://github.com/zenthangplus/goccm

Code:

  1. func main() {
  2.    c := goccm.New(5)
  3.    chanStr := make(chan string)
  4.    lines := []string{&quot;aaaaaa&quot;, &quot;fffff&quot;, &quot;ddddd&quot;, &quot;eeeee&quot;}
  6.    for _, value := range lines {
  7.       value := value
  8.       c.Wait()
  9.       go func() {
  10.          chanStr &lt;- value
  11.          c.Done()
  12.       }()
  13.    }
  15.    for value := range chanStr {
  16.       fmt.Println(value)
  17.    }
  18.    c.WaitAllDone()
  20. }

Before that I did with the channel done to realize that all goroutines are complete and close the channel, but before that I did not limit the number of goroutines.

答案1

得分: 2

在另一个goroutine中从通道中读取：

  1. package main
  3. import (
  4.     "fmt"
  6.     "github.com/zenthangplus/goccm"
  7. )
  9. func main() {
  10.     c := goccm.New(2)
  11.     chanStr := make(chan string)
  12.     lines := []string{"aaaaaa", "fffff", "ddddd", "eeeee"}
  14.     go func() {
  15.         for value := range chanStr {
  16.             fmt.Println(value)
  17.         }
  18.     }()
  20.     for _, value := range lines {
  21.         value := value
  22.         c.Wait()
  23.         go func() {
  24.             chanStr <- value
  25.             c.Done()
  26.         }()
  27.     }
  29.     c.WaitAllDone()
  30.     close(chanStr)
  31. }
英文:

Read from the channel in another goroutine:

  1. package main
  3. import (
  4.     &quot;fmt&quot;
  6.     &quot;github.com/zenthangplus/goccm&quot;
  7. )
  9. func main() {
  10.     c := goccm.New(2)
  11.     chanStr := make(chan string)
  12.     lines := []string{&quot;aaaaaa&quot;, &quot;fffff&quot;, &quot;ddddd&quot;, &quot;eeeee&quot;}
  14.     go func() {
  15.         for value := range chanStr {
  16.             fmt.Println(value)
  17.         }
  18.     }()
  20.     for _, value := range lines {
  21.         value := value
  22.         c.Wait()
  23.         go func() {
  24.             chanStr &lt;- value
  25.             c.Done()
  26.         }()
  27.     }
  29.     c.WaitAllDone()
  30.     close(chanStr)
  31. }

huangapple
  • 本文由 发表于 2023年3月20日 16:04:10
  • 转载请务必保留本文链接：https://go.coder-hub.com/75787773.html
  • concurrency
  • go
  • goroutine
匿名

发表评论

匿名网友

:?: :razz: :sad: :evil: :!: :smile: :oops: :grin: :eek: :shock: :???: :cool: :lol: :mad: :twisted: :roll: :wink: :idea: :arrow: :neutral: :cry: :mrgreen:

确定