Go并发控制之sync.WaitGroup

WaitGroup 会将main goroutine阻塞直到所有的goroutine运行结束，从而达到并发控制的目的。使用方法非常简单，真心佩服创造Golang的大师们！



type WaitGroup               //相当于一个箱子，将main goroutine 保护到里面


func (*WaitGroup) Add   //调用一次为箱子加一把锁（当然，你愿意也可以多把）


func (*WaitGroup) Done  // 调用一次开一把锁（only one！）


func (*WaitGroup) Wait    //箱子的盖子，没锁了自动打开


官网说明：一个WaitGroup锁等待一个goroutines合集结束。main goroutine里面调用Add方法设置需要等待的goroutines 数量，然后运行每一个goroutine，并且当其结束时调用Done方法。同时，main goroutine 被锁住直到所有的goroutines完成。


使用方法（官网Example）：


 var wg sync.WaitGroup   
    var urls = []string{
            "http://www.golang.org/",
            "http://www.google.com/",
            "http://www.somestupidname.com/",
    }
    for _, url := range urls {
            // Increment the WaitGroup counter.
            wg.Add(1)
            // Launch a goroutine to fetch the URL.
            go func(url string) {
                    // Decrement the counter when the goroutine completes.
                    defer wg.Done()
                    // Fetch the URL.
                    http.Get(url)
            }(url)
    }
    // Wait for all HTTP fetches to complete.
    wg.Wait()
				


				
时间： 2024-08-08 16:03:41 

		


		


	

	
	

		


		
Go并发控制之sync.WaitGroup的相关文章


								

		

			

                golang sync.WaitGroup
			

		

		

									

				//阻塞,直到WaitGroup中的所以过程完成. import ( "fmt" "sync" ) func wgProcess(wg *sync.WaitGroup, id int) { fmt.Printf("process:%d is going!\n", id) //if id == 2 { // return //} wg.Done() } func main() { //var wg sync.WaitGroup wg := new(			

		

	

				

		

			

                golang 的 sync.WaitGroup
			

		

		

									

				WaitGroup的用途:它能够一直等到所有的goroutine执行完成,并且阻塞主线程的执行,直到所有的goroutine执行完成. 官方对它的说明如下: A WaitGroup waits for a collection of goroutines to finish. The main goroutine calls Add to set the number of goroutines to wait for. Then each of the goroutines runs and			

		

	

				

		

			

                Go sync.WaitGroup 等待Goroutine执行完成
			

		

		

									

				// A WaitGroup waits for a collection of goroutines to finish.// The main goroutine calls Add to set the number of// goroutines to wait for. Then each of the goroutines// runs and calls Done when finished. At the same time,// Wait can be used to bloc			

		

	

				

		

			

                sync.WaitGroup和sync.Once
			

		

		

									

				sync.WaitGroup,顾名思义,等待一组goroutinue运行完毕.sync.WaitGroup声明后即可使用,它有如下方法: func (wg *WaitGroup) Add(delta int) #不能传入符数,否则引发panic func (wg *WaitGroup) Done() func (wg *WaitGroup) Wait() 一般套路是,"先统一Add, 在并发Done, 最后Wait".中心思想是由一个goroutine或主程序来调用Add和Wait方法			

		

	

				

		

			

                Golang的sync.WaitGroup 实现逻辑和源码解析
			

		

		

									

				在Golang中,WaitGroup主要用来做go Routine的等待,当启动多个go程序,通过waitgroup可以等待所有go程序结束后再执行后面的代码逻辑,比如: func Main() { wg := sync.WaitGroup{} for i := 0; i < 10; i++ { wg.Add(1) go func() { defer wg.Done() time.Sleep(10 * time.Second) }() } wg.Wait() // 等待在此,等所有go func			

		

	

				

		

			

                go语言sync包的学习(Mutex、WaitGroup、Cond)
			

		

		

									

				package main; import ( "fmt" "sync" "runtime" "time" ) //加锁,注意锁要以指针的形式传进来,不然只是拷贝 func total1(num *int, mu *sync.Mutex, ch chan bool) { mu.Lock(); for i := 0; i < 1000; i++ { *num += i; } ch <- true; mu.Unlock(			

		

	

				

		

			

                Go语言sync库和WaitGroup的使用
			

		

		

									

				// code_041_sync_WaitGroup project main.go package main import ( "fmt" "sync" ) func main() { fmt.Println("Hello World!") var wg sync.WaitGroup wg.Add(2) go func() { defer wg.Done() for i := 0; i < 10000; i++ { fmt.Printf(			

		

	

				

		

			

                Golang学习 - sync 包
			

		

		

									

				------------------------------------------------------------ 临时对象池 Pool 用于存储临时对象,它将使用完毕的对象存入对象池中,在需要的时候取出来重复使用,目的是为了避免重复创建相同的对象造成 GC 负担过重.其中存放的临时对象随时可能被 GC 回收掉(如果该对象不再被其它变量引用). 从 Pool 中取出对象时,如果 Pool 中没有对象,将返回 nil,但是如果给 Pool.New 字段指定了一个函数的话,Pool 将使用该函			

		

	

				

		

			

                go语言中sync包和channel机制
			

		

		

									

				文章转载至:https://www.bytelang.com/article/content/A4jMIFmobcA= golang中实现并发非常简单,只需在需要并发的函数前面添加关键字＂Go",但是如何处理go并发机制中不同goroutine之间的同步与通信,golang 中提供了sync包和channel机制来解决这一问题． sync 包提供了互斥锁这类的基本的同步原语.除 Once 和 WaitGroup 之外的类型大多用于底层库的例程.更高级的同步操作通过信道与通信进行. type Co