go语言中的协程

阳光穿透心脏的1/2处 2022-11-15 12:54 162阅读 0赞

go语言中的协程类似与java中的线程，但是又有一些区别，首先我们来说两个容易混淆的概念

*  并发：一般是指多个线程竞争cpu资源，只有竞争到cpu资源的线程，才能被系统分配一个极小的时间段去执行这个线程，这样多个线程每次都会被分配一些极短的时间片来执行，看似是同时执行了，但是对于单核的cpu来说，其实是交替执行，只不过看起来是同时执行一样  
    ![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3NpbGtfamF2YQ_size_16_color_FFFFFF_t_70]
 *  并行：一般是指在多核cpu上，有多个线程被分配到了不同的cpu上进行同时执行了，这是真正意义上的同时执行。但是假如有4个cpu，但是有8个线程，那么此时会既有并发又有并行，因为cpu的数量只能允许4个线程进行并行，也就是说，同一个时间，肯定有至少2个线程去竞争一个cpu资源  
    ![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3NpbGtfamF2YQ_size_16_color_FFFFFF_t_70 1]

java中一个线程大约需要2M的内存，而在go中的协程，只需要2K的内存，并且，在go中要实现一个多协程的程序要比在java中简单的多，所以这也是越来越多的公司开始转型go的原因之一。  
首先来看一个go语言的例子

package main
    
    import (
    	"fmt"
    	"time"
    )
    
    func printNum() {
        
    	for i := 0; i < 10; i++ {
        
    		fmt.Printf("print函数的%d\n", i)
    		time.Sleep(time.Millisecond * 2)
    	}
    }
    func main() {
        
    
    	go printNum()
    	for i := 0; i < 10; i++ {
        
    		fmt.Printf("main函数的%d\n", i)
    		time.Sleep(time.Millisecond)
    	}
    }

打印出的结果

main函数的0
    print函数的0
    main函数的1
    print函数的1
    main函数的2
    main函数的3
    print函数的2
    main函数的4
    main函数的5
    print函数的3
    main函数的6
    main函数的7
    print函数的4
    main函数的8
    print函数的5
    main函数的9

可以看到，主函数比另外起的协程 \*\*printNum()\*\*执行得要快，主函数完全执行完成了，但是printNum并没有执行完成，此时，随着主函数的完成，整个程序就退出了，不会等待另外起的协程执行完成。如果要想等待，就要使用sync包中的锁了。

示例

package main
    
    import (
    	"fmt"
    	"runtime"
    	"sync"
    	"time"
    )
    
    var wg sync.WaitGroup
    
    func test1() {
        
    	for i := 0; i < 10; i++ {
        
    		fmt.Println(fmt.Sprintf("%d   test1", i))
    		time.Sleep(time.Millisecond * 100)
    	}
    	//计数器减去1
    	wg.Done()
    }
    func test() {
        
    	for i := 0; i < 10; i++ {
        
    		fmt.Println(fmt.Sprintf("%d   test", i))
    		time.Sleep(time.Millisecond * 100)
    	}
    	//计数器减去1
    	wg.Done()
    }
    
    //如果主进程执行的比较快，那么test方法可能没有执行完，但是所有的程序已经结束了
    //主线程不会等待协程是否执行完毕
    //为了避免这个bug，需要主线程休眠一下，但是这种方法不好，因为不知道具体要休眠多少
    func main() {
        
    	//计数器加1
    	wg.Add(1)
    	go test() //开启了一个协程
    	wg.Add(1)
    	go test1()
    	//加上这句，表示主线程要等待所有的协程执行完才能结束
    	wg.Wait()
    	fmt.Println("主线程结束")
    
    	cpu := runtime.NumCPU()
    	fmt.Println("本机子的cpu个数", cpu)
    	//设置运行时候使用的最多的cpu的个数
    	runtime.GOMAXPROCS(cpu - 1)
    
    }

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3NpbGtfamF2YQ_size_16_color_FFFFFF_t_70]: /images/20221022/abc1063d3a48438d86ed7e244c5b11b6.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3NpbGtfamF2YQ_size_16_color_FFFFFF_t_70 1]: /images/20221022/89ecd3493d244fc19a92d910dc501276.png