Go语言自学系列 | golang并发编程之协程

Posted COCOgsta

tags:

篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了Go语言自学系列 | golang并发编程之协程相关的知识,希望对你有一定的参考价值。

视频来源:B站《golang入门到项目实战 [2021最新Go语言教程,没有废话,纯干货!持续更新中...]》

一边学习一边整理老师的课程内容及试验笔记,并与大家分享,请移步至知乎网站,谢谢支持!

附上汇总贴:Go语言自学系列 | 汇总 - 知乎 (zhihu.com)https://zhuanlan.zhihu.com/p/484035621


Golang中的并发是函数相互独立运行的能力。Goroutines是并发运行的函数。Golang提供了Goroutines作为并发处理操作的一种方式。

创建一个协程非常简单,就是在一个任务函数前面添加一个go关键字:

Go task()

实例1

package main 
 
import ( 
    "fmt" 
    "time" 
) 
 
func show(msg string)  
    for i := 1; i < 5; i++  
        fmt.Printf("msg: %v\\n", msg) 
        time.Sleep(time.Millisecond * 100) 
     
 
 
func main()  
    go show("java") 
    show("golang") // 在main协程中执行,如果它前面也添加go,程序没有输出 
    fmt.Println("end...") // 主函数退出,程序就结束了 
 
 

运行结果

[Running] go run "d:\\SynologyDrive\\软件开发\\go\\golang入门到项目实战\\goproject\\360duote.com\\pro01\\test.go" 
msg: golang 
msg: java 
msg: golang 
msg: java 
msg: java 
msg: golang 
msg: golang 
msg: java 
end... 
 

查看go关键去掉的运行结果

package main 
 
import ( 
    "fmt" 
    "time" 
) 
 
func show(msg string)  
    for i := 1; i < 5; i++  
        fmt.Printf("msg: %v\\n", msg) 
        time.Sleep(time.Millisecond * 100) 
     
 
 
func main()  
    show("java") 
    show("golang") // 在main协程中执行,如果它前面也添加go,程序没有输出 
    fmt.Println("end...") // 主函数退出,程序就结束了 
 
 

[Running] go run "d:\\SynologyDrive\\软件开发\\go\\golang入门到项目实战\\goproject\\360duote.com\\pro01\\tempCodeRunnerFile.go" 
msg: java 
msg: java 
msg: java 
msg: java 
msg: golang 
msg: golang 
msg: golang 
msg: golang 
end... 
 

实例2

package main 
 
import ( 
    "fmt" 
    "io/ioutil" 
    "log" 
    "net/http" 
    "time" 
) 
 
func responseSize(url string)  
    fmt.Println("Step1: ", url) 
    response, err := http.Get(url) 
    if err != nil  
        log.Fatal(err) 
     
 
    fmt.Println("Step2: ", url) 
    defer response.Body.Close() 
 
    fmt.Println("Step3: ", url) 
    body, err := ioutil.ReadAll(response.Body) 
    if err != nil  
        log.Fatal(err) 
     
    fmt.Println("Step4: ", len(body)) 
 
 
func main()  
    go responseSize("https://www.duoke360.com") 
    go responseSize("https://baidu.com") 
    go responseSize("https://jd.com") 
    time.Sleep(10 * time.Second) 
 
 

运行结果

[Running] go run "d:\\SynologyDrive\\软件开发\\go\\golang入门到项目实战\\goproject\\360duote.com\\pro01\\test.go" 
Step1:  https://jd.com 
Step1:  https://baidu.com 
Step1:  https://www.duoke360.com 
Step2:  https://jd.com 
Step3:  https://jd.com 
Step2:  https://baidu.com 
Step3:  https://baidu.com 
Step4:  343987 
Step4:  141131 
Step2:  https://www.duoke360.com 
Step3:  https://www.duoke360.com 
Step4:  32281 
 

以上是关于Go语言自学系列 | golang并发编程之协程的主要内容,如果未能解决你的问题,请参考以下文章

Go语言学习之旅--并发编程

Go语言学习之旅--并发编程

Go语言自学系列 | golang并发编程之Timer

Go 并发编程之协程及其调度机制

Go语言自学系列 | golang并发编程之runtime包

Go语言自学系列 | golang并发编程之原子操作详解