golang，goroutines，如何在另一个 channel 中设置 channel ，然后在关闭母 channel 后阅读

Question

我是 Golang 的新手，但正在努力理解这门伟大的语言!请帮帮我..

我有 2 个 channel 。 “进”和“出” channel

    in, out := make(chan Work), make(chan Work)

我设置了在 chanel 中监听的 goroutines worker，捕获工作并完成它。我有一些工作，我会寄给香奈儿。

当 Work 由 worker 完成时，它会写入 Out channel 。

func worker(in <-chan Work, out chan<- Work, wg *sync.WaitGroup) {
    for w := range in {

        // do some work with the Work

        time.Sleep(time.Duration(w.Z))
        out <- w
    }
    wg.Done()
}

当所有工作完成后，我会在程序写入时关闭两个 channel 。

现在我想在 OUT channel 中写完成工作的结果，但是在某些部分中将所有内容分开，例如，如果工作类型是这样的:

type Work struct {
    Date string
    WorkType string
    Filters []Filter
}

如果 WorkType 是“firstType”我想将完成的工作发送到一个 channel ，如果 WorkType 是“secondType”到第二个 channel ......但是可能有超过 20 种工作..如何解决这种情况以更好的方式？

我可以在chanel OUT中设置chane，然后从这个子chanel中抓取数据吗？

p.s.: 请原谅我的菜鸟问题..

Answer 1

您可以让输出 channel 是通用的，并使用类型切换处理不同的工作项。

假设您的输出 channel 只是chan interface{}。

就绪工作项的消费者看起来像:

for item := range output {
   // in each case statement x will have the appropriate type
   switch x := item.(type) {
       case workTypeOne:
          handleTypeOne(x)
       case workTypeTwo:
          handleTypeTwo(x)
       // and so on...

       // and in case someone sent a non-work-item down the chan
       default: 
          panic("Invalid type for work item!")
   }
}

并且处理程序处理特定类型，即

func handleTypeOne(w workTypeOne) { 
    ....
}