package main

import ( "fmt" "reflect" "time" )

// 定义一个 int 管道 var intChan chan int

// 定义一个 string 管道 var stringChan chan string

func writeData() { defer wg.Done() for i := 1; i <= 50; i++ { intChan <- i fmt.Println("写入的数据为：", i) time.Sleep(time.Second) } close(intChan) }

func readData() { defer wg.Done() for v := range intChan { fmt.Println("读取的数据为：", v) time.Sleep(time.Second) } }

func main() { // 初始化管道 intChan = make(chan int, 50)

// 启动两个协程
wg.Add(2)
go writeData()
go readData()

// 等待两个协程完成
wg.Wait()

}

这个代码示例展示了如何使用 Go 语言中的管道（channel）来实现协程之间的数据传递。在这个例子中，我们创建了一个用于传递整数的管道 `intChan`，并且定义了两个协程：`writeData()` 和 `readData()`。`writeData()` 协程负责向管道中写入数据，而 `readData()` 协程则负责从管道中读取数据。

在 `main()` 函数中，我们首先初始化了管道 `intChan`，然后启动了两个协程。通过 `wg.Wait()` 语句，我们等待两个协程完成其工作。

需要注意的是，当管道中的数据被读取完毕后，我们需要关闭管道，以避免死锁的发生。在这个例子中，我们在 `writeData()` 函数中使用 `close(intChan)` 语句来关闭管道。

此外，为了避免数据竞争的问题，我们在读写管道时使用了互斥锁（mutex）。在这个例子中，我们使用了 `sync.Mutex` 类型的变量 `mu` 来保护共享资源。

最后，我们还使用了 `time.Sleep()` 函数来控制协程的执行速度，以便观察管道的工作情况。在实际的生产环境中，我们通常不会使用 `time.Sleep()` 函数来控制协程的执行速度，因为这会导致不必要的延迟和资源的浪费。