我们可以使用通道来同步协程之间的执行状态。 这儿有一个例子,使用阻塞接收的方式,实现了等待另一个协程完成。 如果需要等待多个协程,WaitGroup 是一个更好的选择。 |
|
package main |
|
import ( "fmt" "time" ) |
|
我们将要在协程中运行这个函数。
|
func worker(done chan bool) { fmt.Print("working...") time.Sleep(time.Second) fmt.Println("done") |
发送一个值来通知我们已经完工啦。 |
done <- true } |
func main() { |
|
运行一个 worker 协程,并给予用于通知的通道。 |
done := make(chan bool, 1) go worker(done) |
程序将一直阻塞,直至收到 worker 使用通道发送的通知。 |
<-done } |
$ go run channel-synchronization.go working...done |
|
如果你把 |
下一个例子: 通道方向