Golang 程序采用两个单向接收通道和一个发送通道
单向通道是一种通道类型，它既可用于发送数据，也可用于接收数据，但不能同时用于两者。在这篇 Golang 文章中，我们将使用 select 语句以及使用扇入模式方法探索一个采用两个单向接收通道和一个发送通道的 Golang 程序。我们将提供带有算法和代码输出的代码示例。
方法 1:使用 Select 语句
此方法允许您同时处理多个通道操作并选择已准备好处理的通道操作。
算法
创建三个通道:通道一、通道二和输出。
启动 goroutine 以运行 CombineChannels 函数，提供 Channel1、channel2 和 Out 作为参数。
在 CombineChannels 函数内部，执行以下操作 -
使用范围循环从通道 1 接收值并将每个值传输到输出通道。
在通道 1 关闭后，使用范围循环从通道 2 接收值并将每个值传输到输出通道。
关闭输出通道。
在主函数中初始化通道 1、通道 2 和主输出通道。
使用范围循环从输出通道接收值并打印每个接收到的值。
示例
下面给出的示例演示了一种使用 goroutines 将来自多个通道的值组合到单个通道的方法。
package main
import "fmt"
func combineChannels(channel1 <-chan int, channel2 <-chan int, out chan<- int) {
for val := range channel1 {
out <- val
}
for val := range channel2 {
out <- val
}
close(out)
}
func main() {
channel1 := make(chan int)
channel2 := make(chan int)
out := make(chan int)
go combineChannels(channel1, channel2, out)
go func() {
channel1 <- 1
channel1 <- 3
close(channel1)
}()
go func() {
channel2 <- 2
channel2 <- 4
close(channel2)
}()
for val := range out {
fmt.Println(val)
}
}
输出
1 2 3 4
方法 2:使用 Fn-In 模式
Fn-In 代表函数中的函数，是一种管理从多个路由接收的值的自适应方式。它允许您分别管理来自多个通道的值，并对每个通道的值执行各种操作。
算法
创建三个通道:channel1、channel2 和 out。
创建一个名为 wg 的 sync.WaitGroup，初始计数为 2。
启动两个 goroutine:Goroutine 1:mergeChannels(channel1、channel2、out、&wg)
在 mergeChannels 内部:创建另一个名为 mergeWG 的 sync.WaitGroup，初始计数为 2。
启动两个 goroutine −
使用 wg.Done() 减少 wg 的计数。
创建一个名为 results 的切片来存储合并的值，并使用 for val := range out 遍历 out 通道:将每个接收到的值附加到 results 切片。
使用按升序对 results 切片进行排序sort.Ints(results) 并遍历排序后的结果切片并打印每个值。
示例
下面给出的代码演示了一种将两个输入通道的值合并到单个输出通道的方法。然后对合并的值进行排序并显示。
package main
import (
"fmt"
"sort"
"sync"
)
func receiveFromChannel(channel <-chan int, out chan<- int) {
defer close(out)
for val := range channel {
out <- val
}
}
func mergeChannels(channel1 <-chan int, channel2 <-chan int, out chan<- int, wg *sync.WaitGroup) {
defer close(out)
var mergeWG sync.WaitGroup
mergeWG.Add(2)
go func() {
defer mergeWG.Done()
receiveFromChannel(channel1, out)
}()
go func() {
defer mergeWG.Done()
receiveFromChannel(channel2, out)
}()
mergeWG.Wait()
wg.Done()
}
func main() {
channel1 := make(chan int)
channel2 := make(chan int)
out := make(chan int)
var wg sync.WaitGroup
wg.Add(2)
go mergeChannels(channel1, channel2, out, &wg)
go func() {
defer close(channel1)
channel1 <- 1
channel1 <- 3
}()
go func() {
defer close(channel2)
channel2 <- 2
channel2 <- 4
}()
go func() {
wg.Wait()
close(out)
}()
var results []int
for val := range out {
results = append(results, val)
}
sort.Ints(results)
for _, val := range results {
fmt.Println(val)
}
}
输出
1 2 3 4
结论
在本文中，我们讨论了两种不同的方法，即 Go 语言中的 select 语句和 fn-in 方法，它们允许我们将两个单向接收通道中的值合并到单个发送通道中。这种方法在并行处理数据时非常有用，或者在需要处理连续数据流的情况下非常有用。具体应用将取决于您的需求。
