Golang使用channel实现数据通信示例-Golang-PHP中文网

Golang使用channel实现数据通信示例

P粉602998670

发布： 2025-09-17 14:25:01

原创

1798人浏览过

无缓冲channel用于同步通信，发送方阻塞直到接收方就绪；2. 带缓冲channel可暂存数据，减少阻塞，通过range遍历并检测关闭；3. 多生产者并发向同一channel发送数据，主函数统一接收处理。

golang使用channel实现数据通信示例

在Go语言中，channel 是实现goroutine之间通信的核心机制。它不仅用于传递数据，还能保证并发安全。下面通过几个常见示例展示如何使用channel进行数据通信。

1. 基本的channel数据传递

创建一个无缓冲channel，一个goroutine发送数据，另一个接收：

func main() {
    ch := make(chan string)
<pre class='brush:php;toolbar:false;'>go func() {
    ch <- "Hello from goroutine"
}()

msg := <-ch
fmt.Println(msg)

登录后复制

}

这里main函数等待从channel接收数据，发送完成后程序退出。注意：无缓冲channel会阻塞发送方直到有接收方就绪。

立即学习“go语言免费学习笔记（深入）”；

2. 使用带缓冲的channel避免阻塞

当发送频率较高时，可以使用带缓冲的channel临时存储数据：

func main() {
    ch := make(chan int, 3) // 缓冲大小为3
<pre class='brush:php;toolbar:false;'>ch <- 1
ch <- 2
ch <- 3

close(ch)

for num := range ch {
    fmt.Println(num)
}

登录后复制

}

缓冲channel在未满时不阻塞发送，读取时使用range可自动检测channel是否关闭。

芦笋演示

一键出成片的录屏演示软件，专为制作产品演示、教学课程和使用教程而设计。

查看详情

3. 多生产者-单消费者模型

多个goroutine向同一个channel发送数据，主函数统一处理：

func producer(id int, ch chan<- int, wg *sync.WaitGroup) {
    defer wg.Done()
    for i := 0; i < 3; i++ {
        ch <- id*10 + i
        time.Sleep(100 * time.Millisecond)
    }
}
<p>func main() {
ch := make(chan int)
var wg sync.WaitGroup</p><pre class='brush:php;toolbar:false;'>for i := 0; i < 3; i++ {
    wg.Add(1)
    go producer(i, ch, &wg)
}

go func() {
    wg.Wait()
    close(ch)
}()

for num := range ch {
    fmt.Println("Received:", num)
}

登录后复制

}

使用WaitGroup确保所有生产者完成后再关闭channel，防止panic。

4. 使用select监听多个channel

当需要处理多个数据源时，select能实现非阻塞多路复用：

func main() {
    ch1 := make(chan string)
    ch2 := make(chan string)
<pre class='brush:php;toolbar:false;'>go func() { ch1 <- "data from ch1" }()
go func() { ch2 <- "data from ch2" }()

for i := 0; i < 2; i++ {
    select {
    case msg1 := <-ch1:
        fmt.Println(msg1)
    case msg2 := <-ch2:
        fmt.Println(msg2)
    }
}

登录后复制

}

select随机选择就绪的case执行，适合处理并发事件响应。

基本上就这些。channel的设计理念是“不要通过共享内存来通信，而应该通过通信来共享内存”。合理使用channel能写出简洁、安全的并发代码。注意及时关闭不再使用的channel，并避免对已关闭的channel发送数据。

以上就是Golang使用channel实现数据通信示例的详细内容，更多请关注php中文网其它相关文章！