Golang中的sync包的WaitGroup

绝地灬酷狼 2022-11-12 08:27 146阅读 0赞

sync的waitgroup功能

## WaitGroup ##

使用多线程时，进行等待多线程执行完毕后，才可以结束函数，有两个选择

*  channel
 *  waitgroup  
    首先使用channel

func add (n *int , isok chan bool){
        
    	for i :=0 ;i <1000 ; i ++ {
        
    		*n = *n + 1
    	}
    	isok <- true
    }
    func main () {
        
    	var ok = make(chan bool , 2)
    	var i,u = 0,0
    	go add(&i , ok)
    	go add(&i , ok)
    	for <- ok {
        
    		u++
    		if u == 2 {
        
    			break
    		}
    	}
    	fmt.Println(i)
    }

但是，如果线程一旦增多，就会导致代码冗余，增加负担，可以使用sync.WaitGroup包

func add (n *int , wait *sync.WaitGroup) {
        
    	for i := 0 ; i <1000 ; i ++ {
        
    		*n = *n + 1
    	}
    	defer wait.Done()
    }
    func main () {
        
     	var wait sync.WaitGroup
    	var i = 0
    	wait.Add(2)
     	go add(&i , &wait)
    	go add(&i , &wait)
    	wait.Wait()
    	fmt.Println(i)
     }

## 仿sync.WaitGroup功能 ##

type Wait struct {
        //创建一个结构体
    	Num int//线程的个数
    	ok chan bool//线程与函数通信的管道
    }
    func (t *Wait) Add (n int){
        //初始化线程个数
    	t.Num = t.Num + n
    	t.ok = make(chan bool , n)
    }
    func (t *Wait) Done (){
        //执行完一个线程之后，执行的函数，每执行完一个线程，调用函数，使用通信管道进行传输一个true
    	t.ok <- true
    }
    func (t *Wait) Wait () {
        //等待函数，每次管道中放入一个true，说明，执行完一个线程，t.Num--，如果等于0说明所有线程执行结束
    	for <- t.ok {
        
    		t.Num--
    		if t.Num == 0 {
        
    			break
    		}
    	}
    }

发表评论取消回复

表情：

评论列表（有 0 条评论，146人围观）

还没有评论，来说两句吧...

相关阅读

相关 GO语言：sync包——WaitGroup

官网文档对sync包的介绍： Package sync provides basic synchronization primitives such as mutua

「爱情、让人受尽委屈。」/ 2023年10月06日 15:24/ 0 赞/ 52 阅读

相关 golang sync.Pool在1.14中的优化

golang sync.Pool在1.14中的优化 sync.Pool在1.12中实现的原理简述 1.14 Pool 数据结构 poolChain

分手后的思念是犯贱/ 2023年03月14日 05:49/ 0 赞/ 97 阅读

相关 golang sync包中的pool讲解

开始：主要结构主体流程 PUT方法 G

柔光的暖阳◎/ 2023年02月09日 11:57/ 0 赞/ 5 阅读

相关 Go 语言 sync.WaitGroup 等人策略

> 原文 https://www.twle.cn/t/856 小学的我们，都有一大堆的小伙伴一起上下学，有时候某个小伙伴可能起床迟了，那么我们就要等他，然后再一起开开心心上学

刺骨的言语ヽ痛彻心扉/ 2023年02月08日 12:50/ 0 赞/ 3 阅读

相关【Golang】——由浅入深分析并发利器sync.WaitGroup

一、前言官方文档对`sync.WatiGroup`的描述是：一个`waitGroup`对象可以等待一组协程结束，也就等待一组`goroutine`返回。有了

朴灿烈づ我的快乐病毒、/ 2022年11月15日 14:21/ 0 赞/ 165 阅读

相关 Golang中的sync包的WaitGroup

sync的waitgroup功能 WaitGroup 使用多线程时，进行等待多线程执行完毕后，才可以结束函数，有两个选择 channel waitgrou

绝地灬酷狼/ 2022年11月12日 08:27/ 0 赞/ 146 阅读

相关 golang使用sync.WaitGroup把一组协程当作整体来完成的模版

文章目录 golang 中对于协程提供了非常多好用的函数，其中 sync.WaitGroup 可以让我们把一批协程当成一组要运行的程序，等这一批程序运行完之后放可以

╰半夏微凉°/ 2022年09月17日 03:03/ 0 赞/ 183 阅读

相关 golang sync WaitGroup

golang sync WaitGroup 刚才看golang的sync的包，看见一个很有用的功能。就是WaitGroup。先说说WaitGroup的用途：它能

川长思鸟来/ 2022年07月28日 00:20/ 0 赞/ 139 阅读

相关 golang包学习之sync

锁 golang中sync包实现了两种功能的锁Mutex（互斥锁）和RWMutex(读写锁） `type Mutex func (m Mutex) Lock() fu

﹏ヽ暗。殇╰゛Y/ 2022年07月14日 05:19/ 0 赞/ 170 阅读

相关 golang 中 sync.Mutex 和 sync.RWMutex

转载: [https://www.jianshu.com/p/679041bdaa39][https_www.jianshu.com_p_679041bdaa39] 介绍

Myth丶恋晨/ 2022年04月23日 20:24/ 0 赞/ 203 阅读