Golang解决fatal error: all goroutines are asleep - deadlock!

2021-07-14 23:31:54 阅读：631 来源： 互联网

标签：finish jobs results Golang start job asleep deadlock

今天进行一个协程操作demo时总是报错

//workerpool.go
package main

import (
	"fmt"
	"time"
)

//工作线程
func workerPool(jobs <-chan int, results chan<- int) {
	for j := range jobs {
		fmt.Println("start job", j)
		time.Sleep(time.Second) //模拟耗时工作
		fmt.Println("finish job", j)
		results <- j
	}
}

func main() {
	const numJobs = 5
	jobs := make(chan int, numJobs)    //
	results := make(chan int, numJobs) //

	go workerPool(jobs, results)

	for i := 1; i <= numJobs; i++ {
		jobs <- i
	}
        close(jobs)
        for r := range results {
		fmt.Println("results :", r)
	}
}

go run workerpool.go 报错

start job 1
finish job 1
start job 2
results : 1
finish job 2
start job 3
results : 2
finish job 3
start job 4
results : 3
finish job 4
start job 5
results : 4
finish job 5
fatal error: all goroutines are asleep - deadlock!
results : 5

goroutine 1 [chan receive]:
main.main()
	workerpool.go:30 +0x19d

asleep就是说协程都在睡觉没做事
问题应该出在遍历jobs上, jobs遍历完没数据可操作了，引发 asleep - deadlock 报错
改进方法：
1、是无限循环输入数据到jobs
2、用waitGroup

方法1的无限循环输入数据就不做介绍了，比较简单
下面展示一下方法2使用waitGroup的方式


package main

import (
	"fmt"
	"sync"
	"time"
)

var wg sync.WaitGroup

//工作线程
func workerPool(jobs <-chan int, results chan<- int) {
	for j := range jobs {
		fmt.Println("start job", j)
		time.Sleep(time.Second)
		fmt.Println("finish job", j)
		results <- j
	}
}

func init() {
	wg = sync.WaitGroup{}
}

func main() {
	const numJobs = 5
	jobs := make(chan int)    //
	results := make(chan int) //

	go workerPool(jobs, results)
	go func() {
		for r := range results {
			fmt.Println("results :", r)
			wg.Done()//接收到数据,表示完成了一份工作
		}
	}()

	for i := 1; i <= numJobs; i++ {
		wg.Add(1)//标记开始一份工作
		jobs <- i
	}

	wg.Wait()

}

正常运行结果如下：
start job 1
finish job 1
start job 2
results : 1
finish job 2
start job 3
results : 2
finish job 3
start job 4
results : 3
finish job 4
start job 5
results : 4
finish job 5
results : 5

Process finished with exit code 0

标签：finish,jobs,results,Golang,start,job,asleep,deadlock
来源： https://www.cnblogs.com/imbin/p/15013484.html

本站声明： 1. iCode9 技术分享网（下文简称本站）提供的所有内容，仅供技术学习、探讨和分享；
2. 关于本站的所有留言、评论、转载及引用，纯属内容发起人的个人观点，与本站观点和立场无关；
3. 关于本站的所有言论和文字，纯属内容发起人的个人观点，与本站观点和立场无关；
4. 本站文章均是网友提供，不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属；如您发现该文章侵犯了您的权益，可联系我们第一时间进行删除；
5. 本站为非盈利性的个人网站，所有内容不会用来进行牟利，也不会利用任何形式的广告来间接获益，纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。

ICode9

Golang解决fatal error: all goroutines are asleep - deadlock!