golang中并发和并行的示例分析

这篇文章主要介绍了golang中并发和并行的示例分析，具有一定借鉴价值，感兴趣的朋友可以参考下，希望大家阅读完这篇文章之后大有收获，下面让小编带着大家一起了解一下。

什么是golang

golang 是Google开发的一种静态强类型、编译型、并发型，并具有垃圾回收功能的编程语言，其语法与 C语言相近，但并不包括如枚举、异常处理、继承、泛型、断言、虚函数等功能。

golang中默认使用一个CPU，这时程序无法并发，只能是并发。因为始终只有一个CPU在运行。

package main  import (         "fmt"         "runtime" )   //并发和并行 var quit chan int = make(chan int)  func loop() {         for i := 0; i < 100; i++ { //为了观察，跑多些                 fmt.Printf("%d ", i)         }         quit <- 0 }   func main() {         runtime.GOMAXPROCS(2) // 最多使用2个核           go loop()         go loop()           for i := 0; i < 2; i++ {                 <- quit         } }

runtime.GOMAXPROCS(2) 设置使用2个CPU，这才真正是并行。

补充：Go多核并行化

通过goroutine创建相同逻辑CPU核心个数的协程，将求和列表分段，分别计算后汇总。

通过runtime.NUMCPU()获得逻辑CPU个数，并计算每个协程中计算列表的下标，计算完成后，向channel中写入1。

通过向channel中读取int的个数，判断协程运行是否全部完成，之后求和即可。

package main import (	"fmt"	"runtime" ) type Vector []float64 func (v Vector) DoSome(p, i, n int, u Vector, c chan int) {	sum := 0.0	for ; i < n; i++ {	sum += u[i]	}	v[p] = sum	c <- 1 } const NCPU = 4 func (v Vector) DoAll(u Vector) {	c := make(chan int, NCPU)	for i := 0; i < NCPU; i++ {	fmt.Println(i, i*len(u)/NCPU, (i+1)*len(u)/NCPU)	go v.DoSome(i, i*len(u)/NCPU, (i+1)*len(u)/NCPU, u, c)	}	for i := 0; i < NCPU; i++ {	<-c	}	sum := 0.0	for _, value := range v {	sum += value	}	fmt.Println(sum) } func main() {	u := make([]float64, 64)	for i := 0; i < 64; i++ {	u[i] = float64(i)	}	var v Vector = make([]float64, NCPU)	v.DoAll(u)	ncpu := runtime.NumCPU()	fmt.Println(ncpu) }

感谢你能够认真阅读完这篇文章，希望小编分享的“golang中并发和并行的示例分析”这篇文章对大家有帮助，同时也希望大家多多支持亿速云，关注亿速云行业资讯频道，更多相关知识等着你来学习!