Go中的channel是同步还是异步

2024-06-20 01:44

文章标签 go channel 异步同步

本文主要是介绍Go中的channel是同步还是异步，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！

Go语言中的channel可以是异步也可以是同步，这取决与它是否是一个缓冲的channel。

同步channel

无缓冲的channel默认是同步的channel类型，即创建时没有执行缓冲大小。当数据被发送到无缓冲的channel中时，发送者会阻塞直到接受者收到数据。同样，当从无缓冲的channel中接收数据的时候，接受者会阻塞直到发送者发送数据。这种机制允许两个goroutine进行同步的通信。

package mainimport ("fmt"
)func main() {ch := make(chan int)go func() {ch <- 42 // 发送操作会阻塞，直到main goroutine执行接收操作}()fmt.Println(<-ch) // 接收操作，会阻塞直到有值发送到channel
}

异步的channel

有缓冲的channel是异步的，它拥有一个缓冲队列，创建channel的时候指定队列的大小。发送者向有缓冲的channel发送数据的时候，如果缓冲区未满，则发送就不会阻塞，否则发送者同样会阻塞直到有接受者接收到数据。同样，接收者从有缓冲区的channel接收数据时，如果缓冲中有数据，则接收就不会阻塞，否则接收者会阻塞直到缓冲区有发送者发送数据。

package mainimport ("fmt""time"
)func main() {ch := make(chan int, 2) // 创建一个缓冲区大小为2的channel// 向channel发送两个数据ch <- 1ch <- 2go func() {// 延迟1秒后发送第三个数据，此时发送会阻塞，因为缓冲区已满time.Sleep(1 * time.Second)ch <- 3fmt.Println("Sent 3")}()// 主goroutine接收数据fmt.Println(<-ch) // 接收第一个数据，输出1fmt.Println(<-ch) // 接收第二个数据，输出2// 第三个接收操作会阻塞，直到发送者发送第三个数据fmt.Println(<-ch) // 接收第三个数据，输出3
}