当前位置： > > > > 如何将工作人员返回到 Go 中的工作人员池

如何将工作人员返回到 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 中的工作人员池》的内容就介绍到这里了，是不是学起来一目了然！想要了解更多关于的内容请关注米云公众号！