分类导航

Go 发布时间：2022-04-09 发布网站：大佬教程 code.js-code.com

大佬教程收集整理的这篇文章主要介绍了golang基础--Gocurrency并发，大佬教程大佬觉得挺不错的，现在分享给大家，也给大家做个参考。

goroutIne只是由官方实现的超级"线程池"而已，每个实例4-5kb的栈内存占用和用于实现机制而大幅减少的创建和销毁开销。
并发不是并行（多cpu）: Concurrency Is Not Parallelism

并发主要由切换时间片来实现"同时"运行，并行则是直接利用多核实现多线程的运行，但Go可以设置使用核数，以发挥多核计算机的能力。

通过go关键字实现多线程

package main
import (
    "fmt"
    "time"
)

func Go() {
    fmt.Println("1234...") 

}

func main() {
    go Go()                //go关键字构成多线程
    time.Sleep(2 * time.Second) //主程序睡眠2s
}

GoroutIne 奉行通过通信来共享内存，而不是共享内存来通信。

ChAnnel

ChAnnel是goroutIne沟通的桥梁，大都是阻塞同步的
通过make创建，close关闭（当程序简单时，回自动关闭）

package main
import (
    "fmt"
)

func main() {                 //主程序
    c := make(chan bool)      //初始化一个chan类型
    go func() {               //子程序
        fmt.Println("123...") //执行主程序
        c <- true             //通过<-存入bool类型到chan中
    }()
fmt.Println(1)                //程序执行步骤：1st
read_chan := <-c              //<-c 从chan中读取bool，程序执行步骤：2nd
fmt.Println(read_chan)       //程序执行步骤：3rd
}

/*output
1st     1           
2nd     123...
3rd     true
*/

注意以上程序的执行顺序(chAnnel无缓存时)：先执行读取操作c<-c，因为chAnnel中没有值，所以程序发生阻塞，此时执行chanel写操作，然后再执行读操作。

ChAnnel是引用类型
可以使用for range来迭代不断操作chAnnel

package main
import (
    "fmt"
)

func main() {
    c := make(chan bool)      //初始化一个chan类型
    go func() {               //go结合匿名函数，构造并发
        fmt.Println("123...") //执行主程序
        c <- true             //通过<-存入bool类型到chan中
        close(C)              //关闭通道:必须明确在哪个地方关闭
    }()

    for v := range c {       //for循环chanel
    }
}

/*output
    123...
    true
*/

可以设置单向(读&写)或双向通道--默认是双向通道
可以设置缓存大小（默认为0，阻塞），在未被填充前不会发生阻塞（异步），比如缓存20个，可以同时进行20个读操作或者写操作，注意读的操作先于写的操作

package main
import (
    "fmt"
)

func main() { //主程序
    c := make(chan bool,1)   //初始化一个chan类型,缓存为2
    go func() {               //子程序
        fmt.Println("123...") //执行主程序，执行步骤：2
        c <- true             //写操作，执行步骤：2
    }()
    fmt.Println(2)            //执行步骤：1
    fmt.Println(123,<-C)     //读操作，执行步骤：2
    fmt.Println(3)            //执行步骤：3
}

/*output
1   2
2   123...
2   123 true
3   3
    */

设置缓存后，程序为异步，读，写操作同时完成，当读取chAnnal中无数据时，也不会造成堵塞，因为与此同时，写操作也将发生。