golang基础之Gocurrency并发
goroutine只是由官方实现的超级"线程池"而已，每个实例4-5kb的栈内存占用和用于实现机制而大幅减少的创建和销毁开销。
并发不是并行（多CPU）: ConcurrencyIsNotParallelism
并发主要由切换时间片来实现"同时"运行，并行则是直接利用多核实现多线程的运行，但Go可以设置使用核数，以发挥多核计算机的能力。
- 通过go关键字实现多线程
packagemain
import(
"fmt"
"time"
)
funcGo(){
fmt.Println("1234...")
}
funcmain(){
goGo()//go关键字构成多线程
time.Sleep(2*time.Second)//主程序睡眠2s
}
Goroutine奉行通过通信来共享内存，而不是共享内存来通信。
Channel
- Channel是goroutine沟通的桥梁，大都是阻塞同步的
- 通过make创建，close关闭（当程序简单时，回自动关闭）
packagemain
import(
"fmt"
)
funcmain(){//主程序
c:=make(chanbool)//初始化一个chan类型
gofunc(){//子程序
fmt.Println("123...")//执行主程序
c<-true//通过<-存入bool类型到chan中
}()
fmt.Println(1)//程序执行步骤：1st
read_chan:=<-c//<-c从chan中读取bool，程序执行步骤：2nd
fmt.Println(read_chan)//程序执行步骤：3rd
}
/*output
1st1
2nd123...
3rdtrue
*/
注意以上程序的执行顺序(channel无缓存时)：先执行读取操作c<-c，因为channel中没有值，所以程序发生阻塞，此时执行chanel写操作，然后再执行读操作。
- Channel是引用类型
- 可以使用forrange来迭代不断操作channel
packagemain
import(
"fmt"
)
funcmain(){
c:=make(chanbool)//初始化一个chan类型
gofunc(){//go结合匿名函数，构造并发
fmt.Println("123...")//执行主程序
c<-true//通过<-存入bool类型到chan中
close(c)//关闭通道:必须明确在哪个地方关闭
}()
forv:=rangec{//for循环chanel
}
}
/*output
123...
true
*/
- 可以设置单向(读&写)或双向通道--默认是双向通道
- 可以设置缓存大小（默认为0，阻塞），在未被填充前不会发生阻塞（异步），比如缓存20个，可以同时进行20个读操作或者写操作，注意读的操作先于写的操作
packagemain
import(
"fmt"
)
funcmain(){//主程序
c:=make(chanbool,1)//初始化一个chan类型,缓存为2
gofunc(){//子程序
fmt.Println("123...")//执行主程序，执行步骤：2
c<-true//写操作，执行步骤：2
}()
fmt.Println(2)//执行步骤：1
fmt.Println(123,<-c)//读操作，执行步骤：2
fmt.Println(3)//执行步骤：3
}
/*output
12
2123...
2123true
33
*/
设置缓存后，程序为异步，读，写操作同时完成，当读取channal中无数据时，也不会造成堵塞，因为与此同时，写操作也将发生。
以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持毛票票。