[Golang]Coroutine可能存在的死锁

abv123456789 · · 3136 次点击 · · 开始浏览    
这是一个创建于 的文章,其中的信息可能已经有所发展或是发生改变。



直接上代码:

1. 第一种情况, 如果没有select{}, main 主线程不会等待coroutine运行,导致coroutine得不到机会运行。

You are requesting eventual scheduling (using the two go statements) 
of two goroutines and then you exit main without giving the scheduler 
a chance to do anything. 

有了select, 程序正常运行。

  1. package main  
  2.   
  3. import (  
  4.     "fmt"  
  5.         "time"  
  6. )  
  7.   
  8.   
  9. func main() {  
  10.     go func1()  
  11.     go func2()  
  12.     select{}  
  13. }  
  14.   
  15. func func1() {  
  16.        for{  
  17.         fmt.Println("here1")  
  18.             time.Sleep(10 * time.Minute)  
  19.         }  
  20.   
  21. }  
  22.   
  23. func func2() {  
  24.        for{  
  25.        fmt.Println("here2")  
  26.            time.Sleep(10 * time.Minute)  
  27.        }  
}

2. coroutine有机会运行,但是会发生死锁, fatal error: all goroutines are asleep - deadlock!

The goroutine executing func1 exited, ditto for func2. The main goroutine is blocked with no hope to recover while no other goroutine can be scheduled.

  1. package main  
  2.   
  3. import (  
  4.     "fmt"  
  5.     //"time"  
  6. )  
  7.   
  8. func main() {  
  9.     go func1()  
  10.     go func2()  
  11.     select {  
  12.     }  
  13. }  
  14.   
  15. func func1() {  
  16.     fmt.Println("here1")  
  17.   
  18. }  
  19.   
  20. func func2() {  
  21.     fmt.Println("here2")  
  22. }  


3. 第三种情况, 正常运行。

  1. package main  
  2.   
  3. import (  
  4.     "fmt"  
  5. )  
  6.   
  7. var c = make(chan int, 2)  
  8.   
  9. func main() {  
  10.     go func1()  
  11.     go func2()  
  12.     <-c  
  13.     <-c  
  14.     fmt.Println("ok")  
  15. }  
  16.   
  17. func func1() {  
  18.     fmt.Println("here1")  
  19.     c <- 1  
  20. }  
  21.   
  22. func func2() {  
  23.     fmt.Println("here2")  
  24.     c <- 1  
  25. }  

4. 实现上面的目的的另外一种方法:

  1. var wg sync.WaitGroup  
  2.   var urls = []string{  
  3.           "http://www.golang.org/",  
  4.           "http://www.google.com/",  
  5.           "http://www.somestupidname.com/",  
  6.   }  
  7.   for _, url := range urls {  
  8.           // Increment the WaitGroup counter.  
  9.           wg.Add(1)  
  10.           // Launch a goroutine to fetch the URL.  
  11.           go func(url string) {  
  12.                   // Decrement the counter when the goroutine completes.  
  13.                   defer wg.Done()  
  14.                   // Fetch the URL.  
  15.                   http.Get(url)  
  16.           }(url)  
  17.   }  
  18.   // Wait for all HTTP fetches to complete.  
  19.   wg.Wait()  


有疑问加站长微信联系(非本文作者)

本文来自:CSDN博客

感谢作者:abv123456789

查看原文:[Golang]Coroutine可能存在的死锁

入群交流(和以上内容无关):加入Go大咖交流群,或添加微信:liuxiaoyan-s 备注:入群;或加QQ群:692541889

3136 次点击  
加入收藏 微博
暂无回复
添加一条新回复 (您需要 登录 后才能回复 没有账号 ?)
  • 请尽量让自己的回复能够对别人有帮助
  • 支持 Markdown 格式, **粗体**、~~删除线~~、`单行代码`
  • 支持 @ 本站用户;支持表情(输入 : 提示),见 Emoji cheat sheet
  • 图片支持拖拽、截图粘贴等方式上传