是否可以在处理时向Go频道添加项目?
Posted
tags:
篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了是否可以在处理时向Go频道添加项目?相关的知识,希望对你有一定的参考价值。
我正在尝试找到一种使用goroutines递归地完成Go任务的方法。该程序的目标是将一个输入元素带入一个通道,并添加到输出通道输入-1,直到达到0。加工工人的数量应适应。我正在遵循的过程是这样的:
创建输入和输出通道。将起始编号添加到输入通道。初始化工作程序以运行工作程序功能。循环浏览并在输出通道中打印输出。
func main() {
inputChannel := make(chan int, 1)
outputChannel := make(chan int)
inputChannel <- 100
numWorkers := 4
for i := 0; i < numWorkers; i++ {
go worker(inputChannel, outputChannel)
}
for elem := range outputChannel {
fmt.Println("Output: ", elem)
}
}
接下来,在order函数中,我们遍历输入通道中的元素,每次检查是否还有更多元素要接收。如果要接收的元素更多,我们将打印输入元素,从元素中减去1,然后发送到输入通道,以供其他工作人员在元素大于0时使用。如果输入通道中没有剩余内容,则我们返回。
func worker(input chan int, output chan<- int) {
defer close(input)
defer close(output)
for {
element, more := <-input
if more {
fmt.Println("Input: ", element)
element--
if element != 0 {
input <- element
}
} else {
fmt.Println("All Jobs Processed")
return
}
}
}
我看到的输出是:
Input: 100
Input: 99
Input: 98
Input: 97
Input: 96
Input: 95
Input: 94
Input: 93
Input: 92
Input: 91
Input: 90
Input: 89
Input: 88
Input: 87
Input: 86
Input: 85
Input: 84
Input: 83
Input: 82
Input: 81
Input: 80
Input: 79
Input: 78
Input: 77
Input: 76
Input: 75
Input: 74
Input: 73
Input: 72
Input: 71
Input: 70
Input: 69
Input: 68
Input: 67
Input: 66
Input: 65
Input: 64
Input: 63
Input: 62
Input: 61
Input: 60
Input: 59
Input: 58
Input: 57
Input: 56
Input: 55
Input: 54
Input: 53
Input: 52
Input: 51
Input: 50
Input: 49
Input: 48
Input: 47
Input: 46
Input: 45
Input: 44
Input: 43
Input: 42
Input: 41
Input: 40
Input: 39
Input: 38
Input: 37
Input: 36
Input: 35
Input: 34
Input: 33
Input: 32
Input: 31
Input: 30
Input: 29
Input: 28
Input: 27
Input: 26
Input: 25
Input: 24
Input: 23
Input: 22
Input: 21
Input: 20
Input: 19
Input: 18
Input: 17
Input: 16
Input: 15
Input: 14
Input: 13
Input: 12
Input: 11
Input: 10
Input: 9
Input: 8
Input: 7
Input: 6
Input: 5
Input: 4
Input: 3
Input: 2
Input: 1
fatal error: all goroutines are asleep - deadlock!
goroutine 1 [chan receive]:
main.main()
/Users/ianmitchell/go/src/github.com/iancmitchell/channel-recursion/main.go:31 +0x179
goroutine 6 [chan receive]:
main.worker(0xc00004e070, 0xc00005c060)
/Users/ianmitchell/go/src/github.com/iancmitchell/channel-recursion/main.go:9 +0xac
created by main.main
/Users/ianmitchell/go/src/github.com/iancmitchell/channel-recursion/main.go:29 +0xc4
goroutine 7 [chan receive]:
main.worker(0xc00004e070, 0xc00005c060)
/Users/ianmitchell/go/src/github.com/iancmitchell/channel-recursion/main.go:9 +0xac
created by main.main
/Users/ianmitchell/go/src/github.com/iancmitchell/channel-recursion/main.go:29 +0xc4
goroutine 8 [chan receive]:
main.worker(0xc00004e070, 0xc00005c060)
/Users/ianmitchell/go/src/github.com/iancmitchell/channel-recursion/main.go:9 +0xac
created by main.main
/Users/ianmitchell/go/src/github.com/iancmitchell/channel-recursion/main.go:29 +0xc4
goroutine 9 [chan receive]:
main.worker(0xc00004e070, 0xc00005c060)
/Users/ianmitchell/go/src/github.com/iancmitchell/channel-recursion/main.go:9 +0xac
created by main.main
/Users/ianmitchell/go/src/github.com/iancmitchell/channel-recursion/main.go:29 +0xc4
exit status 2
我已经尝试过多种方式来依赖于像这样的渠道并使用等待组,但是我似乎无法使该过程遍历所有项目并发出输出。
好,我们走了。首先,请注意您的代码中存在一些问题。然后修复它们。
如Adrian所说,从已经关闭或没有元素的通道读取。在您的工作人员功能中,您正在这样做。当您在由另一个工作人员关闭输入通道后从输入通道读取元素时,会发生这种情况。
func worker(input chan int, output chan<- int) { defer close(input) ... for { element, more := <-input ... } }
所以,为什么所有工作人员都结束后不关闭输入通道?
解决输入通道的问题后,当您尝试从输出通道读取时,会出现另一个问题。此外,您没有在输出通道上发送任何内容。如果您不需要该频道,那么为什么要使用此频道。并且此输出通道也是未缓冲的(大小为0的通道和发送-接收应同时处于该通道,否则将出现死锁情况)。请参见here和here中的缓冲与非缓冲。也许网络上还有更多有用的文档。感谢我的朋友Nightfury1204从他的this post获得的有关缓冲通道与未缓冲通道的第一条链接。
outputChannel := make(chan int) // unbuffered, no size is defined ... for elem := range outputChannel { fmt.Println("Output: ", elem) }
因此,如果您想向输出通道发送内容,那么逻辑就是您自己的。例如,您可以在worker中完成输入通道处理后发送一些东西。在这种情况下,请将输出通道声明为长度为4的缓冲通道(因为您正在运行4个工作程序)。完成所有工作后,关闭您的输出通道,然后阅读。
outputChannel := make(chan int, 4) // buffered ... // after finishing all your workers close(outputChannel) for elem := range outputChannel { fmt.Println("Output: ", elem) }
注意,请使用
sync.WaitGroup
包中的sync.WaitGroup
等待要完成的goroutine集合。
请参见下面的示例:"sync"
https://play.golang.org/p/WAqwyR0ggNN
以上是关于是否可以在处理时向Go频道添加项目?的主要内容,如果未能解决你的问题,请参考以下文章