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 等待子协程发送完成信号，此时主协程会被阻塞，只有在接收到这个信号后，主协程才会继续执行。确保主协程在子协程完成所有任务后才继续执行，从而实现了同步。