2. 程式人生 > >golang語言漸入佳境[20]-協程與通道

golang語言漸入佳境[20]-協程與通道

阿新 • • 發佈：2018-12-06

協程引入

通過狀態檢查器checkLink，不斷的獲取切片當中的網址，並且列印了出來。
順序執行。這也就意味著，一旦我訪問google.com等網站就會陷入到等待的狀況中。後面的網址無法訪問。

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
 
package main

import (
	"net/http"
	"fmt"
)

func main(){

	links := []string{
		"http://www.baidu.com",
		"http://www.jd.com",
		"http://www.taobao.com"
 
,
		"http://www.163.com",
		"http://www.sohu.com",
	}

	for _,link := range links{
	  	checkLink(link)
	}

}

func checkLink(link string){

	_,err := http.Get(link)
	if err !=nil{
		fmt.Printf(link,"沒有連線上")
		return
	}

	fmt.Println(link,"連線上了")
}

go的協程

在函式的前方，加入go關鍵字，代表開闢一個新的協程。

執行一個go語言的程式的時候，都會開闢一個main協程。子協程通過go的關鍵字來建立。
通過Go的排程器，會將go的協程分配給CPU core取執行。當某一個子協程陷入了暫停或結束，Go的排程器會立即切換到其他的協程工作。因此大大的提高了效率。

但是當前的程式，直接退出了。因為main協程終止以後，子協程全部都會被銷燬。

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
 
package main

import (
	"net/http"
	"fmt"
)

func main(){

	links := []string{
		"http://www.baidu.com",
		"http://www.jd.com",
		"http://www.taobao.com",
		"http://www.163.com",
		"http://www.sohu.com",
	}

	for _,link := range links{
 

		go checkLink(link)  
	}
//main協程終止以後，子協程全部都會被銷燬
}

func checkLink(link string){

	_,err := http.Get(link)
	if err !=nil{
		fmt.Printf(link,"沒有連線上")
		return
	}

	fmt.Println(link,"連線上了")
}

channel通道

通道就是實現協程之間的通訊。

通道的建立

c:= make(chan string) 代表建立了一個通道，此通道只能夠傳遞字串型別。

通道例項

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
 
package main

import (
	"net/http"
	"fmt"
)

func main(){

	links := []string{
		"http://www.baidu.com",
		"http://www.jd.com",
		"http://www.taobao.com",
		"http://www.163.com",
		"http://www.sohu.com",
	}

	c:= make(chan string)
	for _,link := range links{
		go checkLink(link,c)
	}

	fmt.Println(<-c)  //等待通道的訊息並列印，但是這裡只是等待了一條通道。

}

func checkLink(link string,c chan string){ //通道的引數

	_,err := http.Get(link)
	if err !=nil{
		fmt.Printf(link,"沒有連線上")
		c<-"沒有連線上"    //為通道傳遞訊息
		return
	}

	fmt.Println(link,"連線上了")
	c<-"連線上了"//為通道傳遞訊息
}

執行結果

1
2
 
http://www.baidu.com 連線上了
連線上了

上面的程式碼輸出的結果為：
意味著百度連線上之後就退出了。這是由於主協程fmt.Println(<-c)陷入等待，當百度的子協程執行完畢，為通道新增資訊之後。那麼主協程退出，但是其他的協程還沒有執行完畢。但是會直接銷燬。

通道等待

如果想要全部打印出來，增加了多個等待通道的指令。

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
 
package main

import (
	"net/http"
	"fmt"
)

func main(){

	links := []string{
		"http://www.baidu.com",
		"http://www.jd.com",
		"http://www.taobao.com",
		"http://www.163.com",
		"http://www.sohu.com",
	}

	c:= make(chan string)
	for _,link := range links{
		go checkLink(link,c)
	}

	// fmt.Println(<-c)
	// fmt.Println(<-c)
	// fmt.Println(<-c)
	// fmt.Println(<-c)
	// fmt.Println(<-c)
	// fmt.Println(<-c)

  for i:=0;i<len(links);i++{  //等待所有的結果。
		fmt.Println(<-c)
	}
}

func checkLink(link string,c chan string){

	_,err := http.Get(link)
	if err !=nil{
		fmt.Printf(link,"沒有連線上")
		c<-"沒有連線上"
		return
	}

	fmt.Println(link,"連線上了")
	c<-"連線上了"
}

執行結果

1
2
3
4
5
6
7
8
9
10
 
http://www.baidu.com 連線上了
連線上了
http://www.163.com 連線上了
連線上了
http://www.taobao.com 連線上了
連線上了
http://www.sohu.com 連線上了
連線上了
http://www.jd.com 連線上了
連線上了

並不是順序執行的。

通道無限迴圈

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
 
package main

import (
	"net/http"
	"fmt"
)

func main(){

	links := []string{
		"http://www.baidu.com",
		"http://www.jd.com",
		"http://www.taobao.com",
		"http://www.163.com",
		"http://www.sohu.com",
	}

	c:= make(chan string)
	for _,link := range links{
		go checkLink(link,c)
	}

	for{
		go checkLink(<-c,c)   //一旦接收到通道的資訊，就再次的建立協程，將連結作為第一個引數。
	}


}

func  
 

            
  

           

              
              

            

            
相關推薦

			   
            
            
            
 

    


    
    
golang語言漸入佳境[20]-協程與通道

     
 
 協程引入
 通過狀態檢查器checkLink，不斷的獲取切片當中的網址，並且列印了出來。順序執行。這也就意味著，一旦我訪問google.com等網站就會陷入到等待的狀況中。後面的網址無法訪問。
 
  
   
    1234567891011121314151617181920212223242526 



  
 

    


    
    
go語言的協程和通道通訊

     
 
                    
				
				2013-09-17 
				
				周海漢 2013.9.17
許式偉的《go語言程式設計》，有一個簡單的例子，描述go協程和通訊通道chan。挺優美的。如下：

[andy@s1 test]$ cat sum.go
package main 



  
 

    


    
    
協程與go語言併發

     
  
 
 
 https://www.cnblogs.com/liang1101/p/7285955.html 
 https://studygolang.com/articles/10112 
 簡而言之，協程與執行緒主要區別是它將不再被核心排程，而是交給了程式自己排程（意味著程式設計師需要自己編寫排程程式 



  
 

    


    
    
golang的協程和通道的分析

     
 
                
每個協程對應於每個併發的事件，程式可以不用協程，這樣執行的效率不如用協程的要快。
同時執行的協程數，與cpu數進行匹配最合適，否則會出現deadlock。
協程間的通訊，通過chan來實現，而多個chan可以組成管道，來順序的傳遞資料。
<-在chan的左側是用於輸出 



  
 

    


    
    
Python開發——15.協程與I/O模型

     
 沒有   mage   F5   quest   資源   輸入數據   準備   cor   異步   一、協程（Coroutine）
1.知識背景
協程又稱微線程，是一種用戶態的輕量級線程。子程序，或者稱為函數，在所有語言中都是層級調用，比如A調用B，B在執行過程中又調用了C，C執行完畢返回，B執行完畢返 



  
 

    


    
    
【PYTHON模塊】：協程與greenlet、gevent

     
 left   imp   test   bind   lse   調用   編程模型   send   地址   協程：又稱為微線程，英文名稱Coroutine。作用：它擁有自己的寄存器上下文和棧，能保留上一次調用時的狀態，可以隨時暫停程序，隨時切換回來。優點：    ?無需線程上下文切換的開銷    ?無需 



  
 

    


    
    
(轉)通過匯編語言實現C協程

     
 mov   fine   ext   https   context   nbsp   make   oid   reat   轉自：http://www.cnblogs.com/sniperHW/archive/2012/06/19/2554574.html
協程的概念就不介紹了,不清楚的同學可以自己goo 



  
 

    


    
    
Python協程與asyncio

     
 asyncio(解決非同步io程式設計的一整套解決方案，它主要用於非同步網路操作、併發和協程)協程(Coroutine一種使用者態的輕量級微執行緒,它是程式級別的，在執行過程中可以中斷去執行其它的子程式，別的子程式也可以中斷回來繼續執行之前的子程式，無需執行緒上下文切換的開銷) 
get_event_loop 



  
 

    


    
    
swoole 協程與go 協程對比

     
  
 
 date: 2018-5-30 14:31:38 title: swoole| swoole 協程初體驗 description: 通過協程的執行初窺 swoole 中協程的排程; 理解協程為什麼快; swoole 協程和 go 協程對比 
 折騰 swoole 協程有一段時間了, 總結一篇入門貼, 



  
 

    


    
    
Golang原始碼探索(二) 協程的實現原理

     
  
 
 轉自：https://studygolang.com/articles/11627 
 Golang最大的特色可以說是協程(goroutine)了, 協程讓本來很複雜的非同步程式設計變得簡單, 讓程式設計師不再需要面對回撥地獄, 雖然現在引入了協程的語言越來越多, 但go中的協程仍然是實現的是最徹底 



  
 

    


    
    
go語言漸入佳境[3]-變數宣告與賦值

     
 
 變數
 變數是記憶體當中一段空間的抽象描述。變數的型別明確了空間的大小以及空間如何解析。
 Go中的變數型別
 
  
   
    1
    bool byte complex64 complex128 error float32 float64 int int8 int16 int32 int64 



  
 

    


    
    
golang語言漸入佳境[24]-string-大小寫轉換類函式

     
 
 string-大小寫轉換類函式
 
  
   
    123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263
    pa 



  
 

    


    
    
golang語言漸入佳境[23]-string分割類函式

     
 
 string分割類函式
 
  
   
    123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263
    packag 



  
 

    


    
    
golang語言漸入佳境[22]-string檢索類函式

     
 
 string檢索類函式
 
  
   
    12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686 



  
 

    


    
    
golang語言漸入佳境[21]-string型別詳解

     
 
 string的本質
 string是一個引用型別，string包含了兩個部分。一個部分是指標，指向了底層的一個位元組陣列。另一個部分是位元組陣列的長度。當複製字串時，也只是複製了指標與長度。底層的那個位元組陣列是不能夠改變的。字串使用UTF-8編碼。
 列印字串
 
  
   
    12345
   



  
 

    


    
    
golang語言漸入佳境[19]-從go原始碼讀懂interface介面

     
 
 go原始碼中的介面
 http庫中，get方法：
 
  
   
    1
    func Get(url string) (resp *Response, err error)
   
  
 
 Response:
 
  
   
    123456789
    type Response 



  
 

    


    
    
golang語言漸入佳境[18]-interface介面

     
 
 介面宣告與定義
 interface關鍵字，在介面中有函式，但是沒有實現。
 
  
   
    123
    type Phone interface {	call()}
   
  
 
 例子
 一旦有結構體實現了此函式，那麼就可以用介面來接收此結構體。
 
  
   
    123456 



  
 

    


    
    
golang語言漸入佳境[17]-mapping表

     
 
 mapping 宣告
 
  
   
    12345678910111213
    //1、宣告map的方式1var map1 map[string]string//2、宣告map的方式2map2 := make(map[string]string)//3、map中key可以是：int、float 



  
 

    


    
    
golang語言漸入佳境[31]-錯誤處理

     
 
 
  
   
    12345678910111213
    //1、建立error物件的方式1	err1 := errors.New("自己建立的錯誤！")	fmt.Println(err1.Error())	fmt.Println(err1)	fmt.Printf("err1的型別：%T\n", 



  
 

    


    
    
golang語言漸入佳境[30]-rand-package

     
 
 
  
   
    123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566
    package maini