golang goroutine channel实现并发并行

合作：（IT营 四、Goroutine的使用以及 五、启动多个 六、设置Golang并行运行的时候占用的cup数 七、Goroutine统计素 八、Channel管 2、创建 九、Goroutine结合Channel管 十、Golang并发安全和 候就用到了goroutine5种基本状态，它们是：初始态，执行态，是进程的一个执行实例，是程序执行的最小单元，它是比进程更小的能独立运行的基行，如果线程数大于CPU核数，则多线程程序在多个CPU上面运行既有并行又有并发上可以起多个协程。Golang中多协程可以实现并行或者并发。完全由用户自己的程序进行调度的。Golang的一大特色就是从语言层面原生支持协程，在函数或者方法前面加go关键字就可创建一个协程。可以说Golang中的协程就是goroutine。多协程和多线程：Golanggoroutine协程)Java、COS线程（操作系统线程）一般都有固定的栈内存（2MB左右）,goroutine程2KB左右，goroutine切换调度开销方面远比线程要少。这也是为什么越来越多的大公司使用Golang的之一。在主线也每隔50毫秒输出"你好golang",输出10次后，程序，要求主线import()functest()fori:=1;i<=10;i++fmt.Println("tesst() }}funcmain()gotest()//fori:=1;i<=10;i++fmt.Println("main() } import()functest(){fori:=1;i<=10;i++fmt.Println("test()golangfuncmain()gotest()fori:=1;i<=2;i++time.Sleep(time.Millisecond*50) o(iint){ oGoroutine!",i)}funcmain()fori:=0;i<10;i++wg.Add(1)//启动一个goroutine就登记+1 10GoGOMAXPROCSOSGo时调度到8个OS线Goruntime.GOMAXPROCS()CPU逻辑Go1.5版本之前，默认使用的是单执行。Go1.5版本，默认使用全部的CPU逻辑核import)funcmain()cpuNum:=fmt.Println("cpuNum=",runtime.GOMAXPROCS(cpuNum-funcfuncmain()start:=fornum:=1;num<=120000;flagtrue假设是素数fori:=2;i<num;i++{}}ifflag//}}end:=}import)funcfn1(nint){fornum:=(n-1)*30000+1;num<=n*30000;flagtrue假设是素数fori:=2;i<num;i++{ifnum%i==0}}ifflag//}}}funcmain()fori:=1;i<=4;i++{gofn1(i)end:= 使用了goroutine已经能大大的提升新能了，但是如果 Golanggoroutine间的通讯方式，可以使用channel在之间的连接。channelgoroutinegoroutine的通信机制。Go语言中的管道（channel）是一种特殊的类型。管道像一个传送带或者队列，总是遵循先入先出（FirstInFirstOut）的规则，保证收发数据的顺序。每一个管道都是一个具体类型的导管，也就是channel的时候需要为其指定元素类型。varchanvarch1varchanvarch1chan varch2chan varch3chan[]int make(chan元素类型,容量make(chan元素类型,容量ch1:=make(chanint, ch2:=make(chanbool, ch3:=make(chan[]int, chch:=make(chanint,<-xxch从ch goroutine所有的数据都发送完毕的时操作关闭文件是必须要做的，但关闭管道不是必须的。funcmain()chfuncmain()ch:=make(chanint)ch<-10}fatalfatalerror:allgoroutinesareasleep-goroutine1[chanD:/go_demo/demo21/07goroutine/main.go:10+0x5bexitstatus2make函数初始化funcfuncmain()chmake(chanint,1)1ch<-}funcfuncmain()ch<-10ch<-funcfuncmain()ch10ch12 当管道被关闭时，再往该管道发送值会panic，从该管道取值的操作会先取完管道中的packagepackagemainimportfuncfuncmain()varch1=make(chanint,5)fori:=0;i<5;i++{ch1<-i+1close(ch1)关闭管道 forrange,如果没有关闭管fatalerror:allgoroutinesareasleep-//forrangekeyforval:=rangech1{ 2、开启一个fn2的协程han中写入的数import()varwgsync.WaitGroupfuncfn1(intChanchanint){fori:=0;i<100;{intChan<-i+1time.Sleep(time.Millisecond*100)}}funcfn2(intChanchan{forv:=rangeintChanfmt.Printf("readData读到数据=%v\n",v)time.Sleep(time.Millisecond*50)}}funcmain()go import)varwg//intChan1-120000{fori:=1;i<=1000;i++intChan<-}}//intChan取出数据，并判断是否为素数,funcm(intChanchanint,primeChanchanint,exitChanchanbool){varflagbool=truefori:=2;i<num;i++{}}ifflagprimeChan<-num}}}{forv:=rangeprimeChan{}}funcmain()start:=time.Now().Unix()exitChanmake(chanbool8)8//intChan1-8000gofori:=0;i<8;i++{goprim(intChan,primeChan,}gogofunc()fori:=0;i<8;i++} 从exitChan取出了8个结果，就可以放心的关闭prprimeChanfmt.Println(end-start) //1.//1.varchan2chan<-chan2<-20//num:=<-chan2num2:=<-//chan3<-30//err传统的方法在遍历管道时，如果不关闭会阻塞而导致deadlock}

data,ok:=<-data,ok:=<-…景，Go内置了select关键字，可以同时响应多个管道的操作。selectswitchcasecase会对时，就会执行case分支对应的语句。具体格式如下：case<-casedata:=<-casech3<-}import()funcmain()塞而导致deadlock,在实际开发中，可能 intChan:=make(chanint,10)fori:=0;i<10;{intChan<-}stringChan:=make(chanstring,5)fori:=0;i<5;i++{stringChan<-"o"+fmt.Sprintf("%d",}forselect//注意:intChandeadlock，会自动到下一个case匹配casev:=<-fmt.Printf("从intChan的数据%d\n",v)casev:=<-fmt.Printf("从stringChan的数据%s\n",v)fmt.Printf("都取不到了，不玩了程序员可以加入逻辑\n")来。要求使用goroutine完成。import_varmyMap=testn!,让将这个结果放入到functest(nint)res:=fori:=1;i<=n;{res*=funcmain()fori:=1;i<=60;gotest(i)fori,v:=range{fmt.Printf("map[%d]=%d\n",i,互斥锁是一种常用的控制共享资源的方法，它能够保证同时只有一个goroutine可以访问共享资源。GosyncMuteximport_)var )testn!,myMapfunctest(nint){res:=fori:=1;i<=n;{res*=}}funcmain()forfori:=1;i<=60;{gofori,v:=range{fmt.Printf("map[%d]=%d\n",i,并不利于多个协程对全局变量的读写操作。这个时候也可以通过另式来实现上面的互斥锁是完全互斥的，但是有很多实际的场景下是读多写少的，当并发的去一个资写锁在Go语言中使用sync包中的RWMutex类型。取读锁会继续获得锁，如果是获取写锁就会等待；当一个goroutine获取写锁，其他的goroutine无论是获取读锁还是写锁都会等待。varvar rwlocksync.RWMutex)funcwrite()// x=x+) // funcread()//) // funcmain()start:=fori:=0;i<10;{gofori:=0;i<1000;i++goend:=packagepackagemainimport()func o()fori:=0;i<10;