GO语言Channel的基本操作：发送和接收

在Go语言中，通道（channel）是并发编程中的重要概念。它是一种类型化的管道，允许在同一地址空间的多个Goroutine之间进行数据传输。通道的基本操作包括发送和接收数据。

创建通道

首先，你需要使用 make() 函数创建一个通道：

ch := make(chan T)

这里，T 是你希望在通道中传输的数据类型。例如，如果你想创建一个整数类型的通道，可以这样写：

ch := make(chan int)

发送数据到通道

要将数据发送到通道，你可以使用 <- 符号。下面是一个简单的例子：

package main

import "fmt"

func main() {
	ch := make(chan int)

	// 启动一个新的Goroutine来发送数据
	go func() {
		ch <- 42 // 将整数42发送到通道
	}()

	// 在主Goroutine中从通道接收数据
	value := <-ch
	fmt.Println("Received value:", value) // 输出：Received value: 42
}

在这个例子中，我们启动了一个新的Goroutine来发送整数42到通道，然后在主Goroutine中从通道接收该值并打印出来。

接收数据从通道

要从通道接收数据，同样使用 <- 符号。接收操作会阻塞，直到有数据可用。如果通道被关闭并且没有更多数据可用，接收操作将返回零值。

value := <-ch

关闭通道

当你完成所有数据的发送后，可以通过调用 close() 函数来关闭通道。这将通知接收者通道已关闭，不会再有新数据到达。试图向已经关闭的通道发送数据会导致程序 panic。

close(ch)

非缓冲通道 vs. 缓冲通道

Go语言有两种类型的通道：非缓冲通道和缓冲通道。

• 非缓冲通道：这种通道在发送数据之前必须有一个接收者准备接收数据。因此，发送操作将阻塞，直到有接收者准备好。

• 缓冲通道：这种通道可以在内部存储一定数量的数据，不需要接收者立即接收。你可以通过在 make() 函数中指定缓冲区大小来创建缓冲通道：

ch := make(chan T, bufferSize)

示例代码

下面是一个使用无缓冲通道的例子，演示了如何使用通道进行基本的发送和接收操作：

package main

import (
	"fmt"
	"time"
)

func worker(ch chan int) {
	for i := 0; ; i++ {
		fmt.Printf("Worker is sending %d to the channel\n", i)
		ch <- i
		time.Sleep(time.Second)
	}
}

func main() {
	ch := make(chan int)

	go worker(ch)

	for {
		select {
		case v := <-ch:
			fmt.Printf("Received value from the channel: %d\n", v)
		case <-time.After(3 * time.Second):
			fmt.Println("Timeout reached, exiting...")
			return
		}
	}
}

在这个例子中，我们启动了一个名为 worker 的Goroutine，它每秒将一个递增的数字发送到通道。主Goroutine则不断地从通道接收数据，并在接收到三个值或等待三秒钟后退出。

原文链接: https://www.yukx.com/golang/article/details/2424.html 优科学习网GO语言Channel的基本操作：发送和接收