Goroutines 正在休眠

在IT行业这个发展更新速度很快的行业，只有不停止的学习，才不会被行业所淘汰。如果你是Golang学习者，那么本文《Goroutines 正在休眠》就很适合你！本篇内容主要包括##content_title##，希望对大家的知识积累有所帮助，助力实战开发！

我收到致命错误：所有 goroutine 都在睡觉 - 死锁！，即使我正在使用缓冲通道并也得到结果。但在获得所有结果后，我收到错误。

package main

import (
    "fmt"
    "time"
)

func main() {
    StartJobExample()
}

var MAX_NUM = 1000
func StartJobExample(){
    t1 := time.Now()
    jobs := make(chan int,MAX_NUM)
    result:=make( chan int,MAX_NUM)

    go worker(jobs,result)
    writeNums(jobs)


    for j := range result{
        fmt.Println("number read is ",j)
    }
    close(result)

   t2 := time.Now()

   fmt.Println("Time taken in operation ",t2.Sub(t1).Seconds())
}

func  worker(jobs <-chan int ,result chan<- int){
         for i:= range jobs{
                result<-addTwo(i)
         }
}

func writeNums(jobs chan<- int){
    for i:=0;i<MAX_NUM;i++{
        fmt.Println("adding job ",i)
        jobs<-i
    }
    close(jobs)
}

func addTwo(i int)int{
    return i+2
}

解决方案

您的代码中有几个错误，让我们一一检查一下。

首先，在您的情况下，您实际上并不需要缓冲通道，因为它们目前正在帮助掩盖您的真正问题。

其次，writenums函数应该在单独的goroutine中执行。现在，您在同一个 goroutine（main goroutine）中的 jobs 通道中写入并从 result 通道中读取，在您的情况下，这必然会产生死锁。使用缓冲通道掩盖了这个问题。所以，只需这样做：

go writenums(jobs)

第三，你当前的代码永远不会执行这个：

for j := range result{
        fmt.println("number read is ",j)
    }
    close(result)

这就是在您的示例中产生僵局的原因。 result 通道永远不会关闭，因为 close(result) 是在 for 循环之后执行的。您应该将此 close(result) 放在 worker 函数中，位于 for 循环之后。

func  worker(jobs <-chan int ,result chan<- int){
         for i:= range jobs{
                result<-addtwo(i)
         }
         close(result)
}

这样，result 通道将在 jobs 通道关闭后立即关闭，并且 for 循环退出。

Here 是一个使用无缓冲通道的工作示例。您可以修改它以包含缓冲区，但没有它它也可以工作。

编辑：

多个工作人员的解决方案

添加更多 worker goroutine 的主要问题是关闭 result。由于现在有更多的 worker 协程在运行，所有 worker 协程都需要完成将值放入 result 通道，然后才能关闭 result 通道。

这可以通过 sync.waitgroup 等同步机制来完成。以下是更改：

func StartJobExample(){
    t1 := time.Now()
    numberOfWorkers := 5
    jobs := make(chan int)
    result:=make( chan int)
    var wg sync.WaitGroup

    //initialize a goroutine for syncing completion for all workers
    go func() {
      wg.Wait()
      close(result)
    }()
    
    //initialize all workers
    for i :=0; i < numberOfWorkers; i++ {
      wg.Add(1)
      go worker(&wg, jobs, result, i)
    }

// rest of the StartExample function is unchanged
// ...
}

func  worker(wg *sync.WaitGroup, jobs <-chan int ,result chan<- int, num int){
    for i:= range jobs{
           result<-addTwo(i)
    }
    wg.Done()
    fmt.Println("closing worker ", num)
}

在此示例中，您使用 sync.waitgroup 来同步所有 worker goroutine。首先添加一个单独的 goroutine 来等待所有 worker goroutine 完成 (wg.wait()) 并关闭 result 通道。

其次，在创建每个 worker goroutine 之前，需要先执行 wg.add(1) 。

第三，修改 worker 函数，使其可以在从 jobs 通道读取数据并写入 result 通道后执行 wg.done()。

当最后一个 worker goroutine 执行 wg.done() 时，wg.wait() 会解除其 goroutine 中的执行阻塞，并执行 close(result)。 Here 是其工作原理的完整示例。

今天关于《Goroutines 正在休眠》的内容就介绍到这里了，是不是学起来一目了然！想要了解更多关于的内容请关注golang学习网公众号！