Go中的无缓冲通道

作者: Just do it
发布时间: 2024-04-18 06:37:05 (12天前)
转自：

5 条回复

0#
回复此人
晴天 | 2019-08-31 10-32

<div class =“post-text”itemprop =“text”> <P> 无缓冲通道阻塞发送，直到接收器准备好读取。在您的第一个示例中，首先设置一个阅读器，因此当发送时，它可以立即发送。 </p> <P> 在第二个示例中，发送在接收器准备好之前发生，因此发送块和程序死锁。 </p> <P> 您可以通过创建缓冲通道来修复第二个示例，但是有可能您不会看到goroutine的输出，因为程序可能会在刷新输出缓冲区之前退出（主goroutine）。在可以安排之前，goroutine甚至可能不会作为主要出口运行。 </p> </DIV>

编辑
1#
回复此人
Jacob | 2019-08-31 10-32

<div class =“post-text”itemprop =“text”> <P> 首先， <code> go-routines </code> 同时运行。在第一个例子中，sub-goroutine已经启动，但是在第二个例子中，当发送操作出现时，go-routine还没有开始。 </p> <P> 一点一点地思考。 </p> <P> 在第一个例子中， <code> sub-goroutine </code> 在主要的例行程序中出现发送操作之前已同时启动。结果，当发送操作发生时，已经有一个接收器（ <code> sub-goroutine </code> ）存在。 </p> <P> 如果你调整第一个例子， </p> <pre> <code> package main import ( "fmt" "time" ) func main() { ch01 := make(chan string) go func() { fmt.Println("We are in the sub goroutine") fmt.Println(<-ch01) }() // wait for start of sub-routine time.Sleep(time.Second * 2) fmt.Println("We are in the main goroutine") ch01 <- "Hello" // wait for the routine to receive and print the string time.Sleep(time.Second * 2) } </code> </pre> <P> 输出将是 </p> <pre> <code> We are in the sub goroutine We are in the main goroutine Hello </code> </pre> <P> 所以，你可以看到sub-goroutine已经开始了。它正在等待在频道上接收。当主goroutine在通道中发送字符串时，sub-goroutine恢复并接收信号。 </p> <P> 但是在第二个例子中，程序已经停留在主要的例程中 <code> send operation </code> ，sub go例程还没有开始，也不会启动，因为程序尚未获得该行。所以没有其他接收器接收信号。所以程序陷入僵局。 </p> </DIV>

编辑
2#
回复此人
文艺青年 | 2019-08-31 10-32

<div class =“post-text”itemprop =“text”> <P> 对于无缓冲的通道，go例程被阻塞，直到没有人接收它为止。首先应该有一个go例程来从通道接收值，然后发送一个通道值。举例来说，当我们向通道发送一个值时，需要创建一个缓冲通道，以便将值保存到缓冲中，直到没有人接收它为止这样就可以了。 </p> <pre> <code> package main import ( "fmt" "time" ) func main() { ch01 := make(chan string, 10) ch01 <- "Hello" go func() { fmt.Println("We are in the sub goroutine") fmt.Println(<-ch01) }() fmt.Println("We are in the main goroutine") time.Sleep(1 * time.Second) } </code> </pre> <P> <a href="https://play.golang.org/p/NlHIaWFKxtb" rel="nofollow noreferrer"> 操场 </A> </p> </DIV>

编辑
3#
回复此人
Autistic | 2019-08-31 10-32

<div class =“post-text”itemprop =“text”> <BLOCKQUOTE> <P> 这是否意味着在ch01＆lt; - “Hello”之后主要的goroutine立刻阻止，以便sub goroutine没有机会跑？如果是真的，我应该如何理解第一个代码示例的结果？（起初在主要的goroutine，然后在sub goroutine）。 </p> </BLOCKQUOTE> <P> 这是真的。你理解写的东西。未指定产生的goroutine的评估顺序，只能使用同步工具（通道，互斥体）进行控制。第一个示例中的子goroutine也可以在另一个环境中首先打印（）。只是 <EM> 不明 </EM> 。 </p> </DIV>

编辑

登录后才能参与评论