Golang中的sync包的WaitGroup

绝地灬酷狼 2022-11-12 08:27 163阅读 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 条评论，163人围观）

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

相关阅读

相关 GO语言：sync包——WaitGroup

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

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

相关 golang并发之sync包

> 在Go语言并发编程中，提倡\\“使用通信共享内存，不要使用共享内存通信”\\，而这个通信的媒介就是`channel`。 chan是线程安全的，不需要考虑数据冲突问题，面对并

今天药忘吃喽~/ 2023年02月25日 03:37/ 0 赞/ 18 阅读

相关 Golang sync.WaitGroup源码详细分析

一、介绍 WaitGroup是多个goroutine之间协作的一种实现方式，主要功能就是阻塞等待一组goroutine执行完成。常用的使用场景：主gorouti

迷南。/ 2023年02月22日 08:28/ 0 赞/ 11 阅读

相关 golang sync包中的pool讲解

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

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

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

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

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

相关 Golang中的sync包的WaitGroup

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

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

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

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

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

相关 golang sync WaitGroup

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

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

相关 golang包学习之sync

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

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

相关 golang 中 sync.Mutex 和 sync.RWMutex

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

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