英文:
How to call a goroutine inside of a select case that runs in the scope of the select's parent
问题
我正在构建一个数据工具，它可以在流中收集数据并对其进行操作。我有一个主例程，一个“处理管理器”，负责创建累积函数的新例程。管理器根据一个通道接收选择语句来创建例程，该选择语句在一个无限的for循环中运行（我已经为它自身和它创建的所有例程编写了取消例程）。问题是，管理器需要能够在其主范围内运行goroutine累加器，以便它们可以在选择和for循环的范围之外运行（我希望它们在管理器接受新案例时继续运行）。
cancel := make(chan struct{})
chanchannel := make(chan chan datatype)
func operationManager(chanchannel chan chan datatype, cancel chan struct{}) {
for {
select {
case newchan := <-chanchannel:
go runAccum(newchan, cancel)
case <-cancel:
return
}
}
}
func runAccum(inchan chan datatype, cancel chan struct{}) {
for {
select {
case data := <-inchan:
//do something
case <-cancel:
return
}
}
}
这只是我使用情况的一个非常简化的示例，但我希望它能说明我的问题的组成部分。如果这是可能的、可行的、合理的、不可取的，请告诉我；不，这不是我实现拆除的方式哈哈。
英文:
I am building a data tool that collects data in a stream and operates on it. I have a main routine, a "process manager", which is responsible for creating new routines of an accumulation function. The manager is informed to create the routines based on a channel receive select case which it is running in an infinite for loop (I already have my cancel routine for itself and all of the routines it creates). The problem is that the manager needs to be able to run the goroutine accumulators in its main scope so that they can operate outside of the select and for loop's scope (I want them to keep running while the manager accepts new cases).
cancel := make(chan struct{})
chanchannel := make(chan chan datatype)
func operationManager (chanchannel chan chan datatype, cancel chan struct{}) {
for {
select {
case newchan := <- chanchannel:
go runAccum(newchan, cancel)
case <- cancel:
return
}
}
}
func runAccum(inchan chan datatype, cancel chan struct{}) {
for {
select {
case data := <- inchan;
//do something
case <- cancel:
return
}
}
}
This is a very, very dumbed-down example of my use-case, but I hope it illustrates my problem's component pieces. Let me know if this is possible, feasible, reasonable, inadvisable; And no, this is not how I implemented my teardown haha
答案1
得分: 1
协程（goroutine）没有“作用域”的概念。所有的协程都是平等的。
闭包有“作用域”的概念，但是你的协程并不跨越闭包。
所以，通过go runAccum(newchan, cancel)启动的所有协程，与你从任何地方启动的其他协程一样。
我猜你没有测试你的解决方案？
英文:
There is no "scope" to goroutines. All goroutines are equal.
There is "scope" for closures but your goroutines do not span closures.
So all your goroutines spanned by go runAccum(newchan, cancel) will be like any other goroutine you span, no matter from where.
I assume you did not test your solution?
通过集体智慧和协作来改善编程学习和解决问题的方式。致力于成为全球开发者共同参与的知识库，让每个人都能够通过互相帮助和分享经验来进步。
评论