GO 計算所有并發(fā)任務(wù)的總時(shí)間 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() }

?

?

開(kāi)發(fā)過(guò)程中，經(jīng)常遇到task之間的同步問(wèn)題。例如，多個(gè)子task并發(fā)完成一部分任務(wù)，主task等待他們最后結束。

?

在Go語(yǔ)言，實(shí)現同步的一種方式就是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))

?