您的位置:首页 > 房产 > 建筑 > go语言协程之间的同步

go语言协程之间的同步

2024/12/23 16:48:04 来源:https://blog.csdn.net/canyuemanyue/article/details/141201320  浏览:    关键词:go语言协程之间的同步

前言

Channels 是 Go 语言中用于 协程之间通信的机制。它允许在协程之间发送和接收数据,实现数据同步。

一、channel创建

ch := make(chan int) // 创建一个 int 类型的 channel

二、channel实现数据发送与接收

ch := make(chan int) // 创建一个 int 类型的 channel// 发送数据
go func() {ch <- 42
}()// 接收数据
value := <-ch
fmt.Println(value) // 输出: 42

三、子协程与主协程之间实现同步

package mainimport ("fmt""time"
)// 子协程函数
func produceData(ch chan<- int, done chan<- bool) {for i := 0; i < 5; i++ {ch <- itime.Sleep(500 * time.Millisecond)}close(ch)    // 发送完数据后关闭 channeldone <- true // 通知主协程任务完成
}func main() {dataChannel := make(chan int)doneChannel := make(chan bool)// 启动子协程,调用 produceData 函数go produceData(dataChannel, doneChannel)// 主协程从 dataChannel 中接收数据for value := range dataChannel {fmt.Println("主协程接收到数据:", value)}// 等待子协程通知完成<-doneChannelfmt.Println("子协程已完成,主协程继续执行")
}

子协程和主协程是并行运行的。子协程和主协程分别在不同的执行线程中同时进行操作,使用 <-doneChannel 等待子协程发送完成信号,此时主协程会被阻塞,只有在接收到这个信号后,主协程才会继续执行。确保主协程在子协程完成所有任务后才继续执行,从而实现了同步。

版权声明:

本网仅为发布的内容提供存储空间,不对发表、转载的内容提供任何形式的保证。凡本网注明“来源:XXX网络”的作品,均转载自其它媒体,著作权归作者所有,商业转载请联系作者获得授权,非商业转载请注明出处。

我们尊重并感谢每一位作者,均已注明文章来源和作者。如因作品内容、版权或其它问题,请及时与我们联系,联系邮箱:809451989@qq.com,投稿邮箱:809451989@qq.com