重新引入通道导致程序阻塞

目前golang学习网上已经有很多关于Golang的文章了，自己在初次阅读这些文章中，也见识到了很多学习思路；那么本文《重新引入通道导致程序阻塞》，也希望能帮助到大家，如果阅读完后真的对你学习Golang有帮助，欢迎动动手指，评论留言并分享~

我有稳定的入站“作业”流，将其输入到无缓冲通道中。我有一个 for range 循环来迭代项目并处理它们。如果处理该项目失败，我会将项目重新插入通道中，以便稍后重试。

问题是当我将项目重新插入通道时 - 它陷入僵局。我明白为什么会发生这种情况：处理器在尝试发送时不会从通道中读取数据，因此发送会永远阻塞。但我想不出解决问题的模式。有人可以帮忙找到解决方案吗？

这是一个简单的示例代码，显示了我的问题（https://play.golang.org/p/n_-jwl5aoco）：

package main

import (
    "fmt"
    "time"
)

type Job struct {
    ID       int
    Attempts int
}

func main() {
    ch := make(chan *Job)
    go fetchJobs(ch)

    for job := range ch {
        if success := processJob(job); !success {
            ch <- job
        }
    }
}

func processJob(job *Job) bool {
    job.Attempts++
    fmt.Printf("Processing job %+v\n", job)

    // Simulate work.
    time.Sleep(time.Millisecond * 500)

    // Simulate failure on some jobs (IDs 10 to 19, 30 to 39, etc.)
    if job.ID%20 >= 10 && job.Attempts == 1 {
        return false
    }

    return true
}

func fetchJobs(ch chan *Job) {
    for i := 0; ; i++ {
        ch <- &Job{ID: i}
    }
}

解决方案

最简单的解决方案是使用一个新的 goroutine 将其放回去：

if success := processJob(job); !success {
    go func() { ch <- job }()
}

如果您想避免为此使用新的 goroutine，另一个解决方案是“存储”失败的作业。最简单的存储可能是切片。如果作业处理失败，则将该作业追加到失败的作业中。

生产者在获取新作业之前（或之后，取决于您想要重新排队失败作业的“速度”）可以检查是否有失败作业，如果有，则将其中一些（或全部）排队。当然，必须同步对失败作业存储的访问。

另请注意，您不应无条件地重新排队失败的作业，因为如果错误是永久性的，它们将永远不会完成，可能会阻塞整个系统。一个简单的解决方法是仅在重试计数器小于限制时重新排队。

尽管如果您有一个无缓冲的作业通道以及单个生产者和消费者，则重新排队可能会造成不必要的复杂化。您也可以对失败的作业重试几次，如果在某些重试或时间限制内无法成功，则将其处理为可撤消。

以上就是本文的全部内容了，是否有顺利帮助你解决问题？若是能给你带来学习上的帮助，请大家多多支持golang学习网！更多关于Golang的相关知识，也可关注golang学习网公众号。