是否可以在处理时向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的通道和发送-接收应同时处于该通道,否则将出现死锁情况)。请参见herehere中的缓冲与非缓冲。也许网络上还有更多有用的文档。感谢我的朋友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频道添加项目?的主要内容,如果未能解决你的问题,请参考以下文章

如何在运行时向转发器项目添加属性?

安装包时向 .env 添加新的环境变量

在运行时向兔子侦听器动态添加队列

在 go 中输入不可知的频道

将项目拖动到它时向 Navigationviewitem 添加显示

在运行时向 Gridview 动态添加行