当前位置： > > > > 如何将工作人员返回到 Go 中的工作人员池
来源：stackoverflow
2024-04-26 09:54:35
0浏览
收藏
哈喽！今天心血来潮给大家带来了《如何将工作人员返回到 Go 中的工作人员池》，想必大家应该对Golang都不陌生吧，那么阅读本文就都不会很困难，以下内容主要涉及到，若是你正在学习Golang，千万别错过这篇文章~希望能帮助到你！
问题内容
我正在实现一个工作池，它可以从通道中获取作业。在不断超时后，我意识到当worker fcn内发生panic时，即使我实现了恢复机制，worker仍然不会再次返回到池中。
在 golang 演示中，我能够复制这个问题：
工作池参考
修改后的操场代码：
package main
import "fmt"
import "time"
import "log"
func recovery(id int, results chan<- int) {
if r := recover(); r != nil {
log.print("in recovery func - failed worker: ",id)
results <- 0
}
}
func worker(id int, jobs <-chan int, results chan<- int) {
for j := range jobs {
defer recovery(id, results)
if id == 1 {
panic("test")
}
fmt.println("worker", id, "started job", j)
time.sleep(time.second)
fmt.println("worker", id, "finished job", j)
results <- j * 2
}
}
func main() {
jobs := make(chan int, 100)
results := make(chan int, 100)
for w := 1; w <= 3; w++ {
go worker(w, jobs, results)
}
for j := 1; j <= 10; j++ {
jobs <- j
}
close(jobs)
for a := 1; a <= 10; a++ {
<-results
}
}
为了进行测试，我在使用工人 1 时实现了恐慌。运行时，func 按预期发生恐慌，并按预期进入恢复状态（也不将值推送到通道中），但工作线程 1 似乎永远不会回来。
输出无恐慌：
worker 3 started job 1 worker 1 started job 2 worker 2 started job 3 worker 1 finished job 2 worker 1 started job 4 worker 3 finished job 1 worker 3 started job 5 worker 2 finished job 3 worker 2 started job 6 worker 3 finished job 5 worker 3 started job 7 worker 1 finished job 4 worker 1 started job 8 worker 2 finished job 6 worker 2 started job 9 worker 1 finished job 8 worker 1 started job 10 worker 3 finished job 7 worker 2 finished job 9 worker 1 finished job 10
带有恐慌的输出：
worker 3 started job 1 2009/11/10 23:00:00 RECOVERY Failed worker: 1 worker 2 started job 3 worker 2 finished job 3 worker 2 started job 4 worker 3 finished job 1 worker 3 started job 5 worker 3 finished job 5 worker 3 started job 6 worker 2 finished job 4 worker 2 started job 7 worker 2 finished job 7 worker 2 started job 8 worker 3 finished job 6 worker 3 started job 9 worker 3 finished job 9 worker 3 started job 10 worker 2 finished job 8 worker 3 finished job 10
恢复后（或恢复过程中）如何将工作线程 1 返回到池中
解决方案
如果您关心错误，您可以将 errors 通道传递到工作函数中，如果它们遇到 error，请将其发送到通道，然后 continue。主循环可以处理这些错误。
或者，如果您不关心该错误，只需 continue 即可跳过该作业。
语句基本上停止处理循环的迭代，并继续下一个。
今天关于《如何将工作人员返回到 Go 中的工作人员池》的内容就介绍到这里了，是不是学起来一目了然！想要了解更多关于的内容请关注公众号！
