在学习go语言时,用到了“sync”包中的WaitGourp结构,来达到控制任务的完成。
由于WaitGroup是结构,所有需要通过sync.WaitGroup{}来创建
很类似与 Shoper/JAVA并发库之倒记时锁存器CountDownLatch中的CountDownLatch类。
Add(),Done(),Wait()。其中Done()是Add(-1)的别名。简单的来说,使用Add()添加计数,Done()减掉一个计数,计数不为0, 阻塞Wait()的运行。
package main import ( "fmt" "runtime" "sync" ) func main() { runtime.GOMAXPROCS(runtime.NumCPU()) waitGourp := sync.WaitGroup{} waitGourp.Add(10) for i := 0; i < 10; i++ { go Go(&waitGourp, i) } waitGourp.Wait() } func Go(wg *sync.WaitGroup, index int) { sum := 0 for i := 0; i < 100000000; i++ { sum += i } fmt.Println(index, sum) wg.Done() }
PS:由于之前用的是java,方法的参数传递是值传递,而在此go中是区分值传递和引用传递的.
而由于结构是值类型,所以再作为法参数传递时应传递结构的引用(地址)。
有疑问加站长微信联系(非本文作者)