Golang 创建单向发送通道，并将其传递给接受指向整数切片的指针的函数

在使用Go语言通道时，有许多情况下您需要编写一个程序来创建单向发送通道，并将其传递给一个接受指向整数切片的指针的函数，用于数据流传输、异步数据共享等。在本篇Go语言文章中，我们将使用make()函数以及通道类型来编写这样一个程序。

语法

ch := make(chan<- string)

声明一个只发送的通道，名为“ch”。

go sendOnlyChannel(ch, &wg)

要启动一个新的goroutine，我们使用“go”关键字。这里，go关键字正在执行SendOnlyChannel()函数。

var wg sync.WaitGroup

Sync.WaitGroup，被定义为一个变量，用于同步goroutine。

步骤

定义sendData函数，接受类型为chan int的单向传输通道ch和整数切片data作为参数。
遍历data切片中的每个val值：向通道ch发送值val。
关闭通道ch来表示不再发送额外的值。
确定主函数。创建一个包含值1,2,3,4,5的整数切片data。
使用make()方法创建一个类型为”chan int”的双向通道ch。
调用sendData方法，将通道ch和数据切片作为参数传递，以启动一个goroutine。
进入循环以接收通过通道发送的值。打印出”val”。

示例1

下面的代码创建一个通道，并启动一个独立的goroutine将切片中的值发送到通道，另一个goroutine打印这些值。这段代码是go语言中通道之间并发通信的示例。

package main
import "fmt"
func sendData(ch chan<- int, data []int) {
   for _, val := range data {
      ch <- val
   }
   close(ch)
}
func main() {
   data := []int{1, 2, 3, 4, 5}
   ch := make(chan int)
   go sendData(ch, data)
   for val := range ch {
      fmt.Println(val)
   }
}

输出

示例2

这段代码是go语言中通道之间并发通信的一个示例。这段代码引入了”done”通道，”done”通道用作完成的信号，它允许主goroutine在发送通道完成执行之前等待。

package main
import (
   "fmt"
)
func sendData(ch chan<- int, data *[]int, done chan<- bool) {
   for _, val := range *data {
      ch <- val
}
close(ch)
done <- true
}
func main() {
   data := []int{1, 2, 3, 4, 5}
   ch := make(chan int)
   done := make(chan bool)
   go sendData(ch, &data, done)
   for val := range ch {
      fmt.Println(val)
   }
   // Waiting to receive a value indicating completion
   <-done
}