golang语言渐入佳境[20]-协程与通道

发布时间：2020-07-25 11:41:37 阅读：409 作者：jonson_jackson 栏目：开发技术

GO开发者专用服务器限时活动，0元免费领，库存有限，领完即止！点击查看>>

协程引入

通过状态检查器checkLink，不断的获取切片当中的网址，并且打印了出来。
顺序执行。这也就意味着，一旦我访问google.com等网站就会陷入到等待的状况中。后面的网址无法访问。

123456789101112131415161718192021222324252627282930313233

package mainimport (	"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协程终止以后，子协程全部都会被销毁。

123456789101112131415161718192021222324252627282930313233

package mainimport (	"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) 代表创建了一个通道，此通道只能够传递字符串类型。

通道实例

1234567891011121314151617181920212223242526272829303132333435363738

package mainimport (	"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<-"连接上了"//为通道传递消息}

执行结果

12	http://www.baidu.com 连接上了连接上了

上面的代码输出的结果为：
意味着百度连接上之后就退出了。这是由于主协程fmt.Println(<-c)陷入等待，当百度的子协程运行完毕，为通道添加信息之后。那么主协程退出，但是其他的协程还没有运行完毕。但是会直接销毁。

通道等待

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

12345678910111213141516171819202122232425262728293031323334353637383940414243444546

package mainimport (	"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<-"连接上了"}

执行结果

12345678910

http://www.baidu.com 连接上了连接上了http://www.163.com 连接上了连接上了http://www.taobao.com 连接上了连接上了http://www.sohu.com 连接上了连接上了http://www.jd.com 连接上了连接上了

并不是顺序执行的。

通道无限循环

1234567891011121314151617181920212223242526272829303132333435363738394041

package mainimport (	"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 checkLink(link string,c chan string){	_,err := http.Get(link)	if err !=nil{		fmt.Printf(link,"没有连接上")		c<-link     //将链接放置到通道中		return	}	fmt.Println(link,"连接上了")	c<-link  //将链接放置到通道中}

go的通道遍历

比上一个代码效果一样，更加的清晰

1234567891011121314151617181920212223242526272829303132333435363738394041424344

package mainimport (	"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)	//}	for l:=range c{		go checkLink(l,c)	}}func checkLink(link string,c chan string){  	time.Sleep(2*time.Second) //等待两秒钟	_,err := http.Get(link)	if err !=nil{		fmt.Printf(link,"没有连接上")		c<-link		return	}	fmt.Println(link,"连接上了")	c<-link}

高级写法的错误代码

下面的代码有一个非常严重的问题，

123456789101112131415161718192021222324252627282930313233343536373839

package mainimport (	"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)	}//下面的代码有一个非常严重的问题，当等待2秒钟之后，l这个地址的字符串全部变为了相同的了。并传递到了所有的协程中。	for l:=range c{		go func() {    	time.Sleep(2*time.Second)			checkLink(l,c)		}()	}}func checkLink(link string,c chan string){	_,err := http.Get(link)	if err !=nil{		fmt.Printf(link,"没有连接上")		c<-link		return	}	fmt.Println(link,"连接上了")	c<-link}

更高级的正确写法

上面写法的改进，不再是引用，而是每一个副本。传递到函数中。

123456789101112131415161718192021222324252627282930313233343536373839404142

package mainimport (	"net/http"	"fmt"	"time")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 l:=range c{		go func(link string) {    //上面写法的改进，不再是引用，而是每一个副本。首先传递到函数中。			time.Sleep(2*time.Second)			checkLink(link,c)  		}(l)	}}func checkLink(link string,c chan string){	_,err := http.Get(link)	if err !=nil{		fmt.Printf(link,"没有连接上")		c<-link		return	}	fmt.Println(link,"连接上了")	c<-link}

本文链接： https://dreamerjonson.com/2018/11/27/golang-20-channel/
版权声明： 本博客所有文章除特别声明外，均采用 CC BY 4.0 CN协议许可协议。转载请注明出处！

golang语言渐入佳境[20]-协程与通道

亿速云「云服务器」，即开即用、新一代英特尔至强铂金CPU、三副本存储NVMe SSD云盘，价格低至29元/月。点击查看>>

向AI问一下细节

golang语言渐入佳境[20]-协程与通道

协程引入

go的协程

channel通道

通道的创建

通道实例

执行结果

通道等待

执行结果

通道无限循环

go的通道遍历

高级写法的错误代码

更高级的正确写法

猜你喜欢

最新资讯

相关推荐

开发者交流群：

相关标签