GO 计算所有并发任务的总时间 WaitGroup

func worker(t *testing.T, client *ChainClient, count int, wg *sync.WaitGroup) { for i := 0; i < count; i++ { _, err := testUserContractClaimInvoke(client, "save", false) require.Nil(t, err) } wg.Done() }

 

 

开发过程中，经常遇到task之间的同步问题。例如，多个子task并发完成一部分任务，主task等待他们最后结束。

 

在Go语言，实现同步的一种方式就是WaitGroup。

t1 := time.Now() var wg sync.WaitGroup for i := 0; i <= 10; i++ { wg.Add(1) go worker(t, client,1, &wg) } wg.Wait() t2 := time.Now() fmt.Println("total time:") fmt.Println(t2.Sub(t1))