go sync 包 WaitGroup 的使用

 基础语法  2022-06-09  admin  600  810

sync包提供了基本的同步基元,如互斥锁。除了Once和WaitGroup类型,大部分都是适用于低水平程序线程,高水平的同步使用channel通信更好一些。

package main

import (
	"fmt"
	"sync"
)

func main() {
	var wg sync.WaitGroup
	items := []int{1, 2, 3, 4, 5, 6, 7, 8, 9, 10}
	// 使用for循环创建所需的Goroutine
	for index, _ := range items {
		// 每次调用sync.Add()都会增加sync.WaitGroup变量中的计数器。需要注意的是,在go语句之前调用sync.Add(1)非常重要,以防止出现任何竞争条件。
		//wg.Add(1)
		wg.Add(2)
		index := index
		go func() {
			fmt.Printf("item:%v \n", items[index])
			// 当每个Goroutine:完成其工作时,将执行sync.Done()函数,以减少相同的计数器。
			defer wg.Done()
			defer wg.Done()
		}()
	}
	fmt.Printf("%#v\n", wg)
	//sync.Wait()调用将阻塞,直到sync.WaitGroup 变量中的计数器为零,从而保证所有Goroutine能执行完成。
	wg.Wait()
}

当Add()和Done()的数量不匹配时会发生什么?

代码可能会执行,但是会panic: sync: negative WaitGroup counter 错误.

如果文章对您有帮助,点击下方的广告,支持一下作者吧!

转载必须注明出处:

go sync 包 WaitGroup 的使用 —— code.cent123.com

相关推荐


在go协程中共享资源需要加锁处理

在go协程中共享资源需要加锁处理packagemain import( "fmt" "sync" ) //创建一个互斥锁 varmutex=&sync.Mutex{} //定义一个共享资源 varsharedResource=0 //定义一个等待组 varwg=sync.WaitGroup{} //定义一

go WaitGroup 的使用方法

在 Go 中,sync 包下的 WaitGroup 能有助于我们控制协程之间的同步。当需要等待一组协程都执行完各自任务后,才能继续后续逻辑。这种场景,就非常适合使用它。WaitGroup 提供三个 API。Add(delta int) 函数提供了 WaitGroup 的任务计数,delta 的值可以为正也可以为负,通常在添加任务时使用。Done() 函数其实就是 Add(-1),在任务完成时调用。

Go 中 实现基于 channel 的简单 生产者 消费者模型

Go 中 实现基于 channel 的简单 生产者 消费者模型packagemain import( "fmt" "strconv" "sync" ) //生产者 funcproducer(chchan<-string,wg*sync.WaitGroup){ deferwg.Done() fo

go 协程管理及传参处理

Go语言中的goroutine虽然相对于系统线程来说比较轻量级(初始栈大小仅2KB),(并且支持动态扩容),而正常采用java,c++等语言启用的线程一般都是内核态的占用的内存资源一般在4m左右,而假设我们的服务器CPU内存为4G,那么很明显才用的内核态线程的并发总数量也就是1024个,相反查看一下Go语言的协程则可以达到4*1024*1024/2=200w.这么一看就明白了为什么Go语言天生支持