Go語言定時(shí)器怎樣處理并發(fā)任務(wù)

在Go語言中，可以使用time包中的Timer類型來處理并發(fā)任務(wù)。Timer類型提供了一個(gè)定時(shí)器，可以在指定的時(shí)間間隔后觸發(fā)一個(gè)事件。你可以使用sync.WaitGroup來確保所有并發(fā)任務(wù)都完成后再繼續(xù)執(zhí)行后續(xù)代碼。

下面是一個(gè)簡單的示例，展示了如何使用Timer和sync.WaitGroup處理并發(fā)任務(wù)：

package main

import (
	"fmt"
	"sync"
	"time"
)

func task(id int, wg *sync.WaitGroup, timer *time.Timer) {
	defer wg.Done() // 在任務(wù)完成時(shí)調(diào)用Done()通知WaitGroup

	<-timer.C // 等待定時(shí)器觸發(fā)
	fmt.Printf("Task %d started\n", id)
	time.Sleep(2 * time.Second) // 模擬任務(wù)執(zhí)行時(shí)間
	fmt.Printf("Task %d finished\n", id)
}

func main() {
	var wg sync.WaitGroup
	timer := time.NewTimer(1 * time.Second) // 創(chuàng)建一個(gè)定時(shí)器，1秒后觸發(fā)

	for i := 1; i <= 5; i++ {
		wg.Add(1) // 為每個(gè)任務(wù)增加一個(gè)計(jì)數(shù)
		go task(i, &wg, timer) // 啟動(dòng)并發(fā)任務(wù)
	}

	wg.Wait() // 等待所有任務(wù)完成
	fmt.Println("All tasks completed")
}

在這個(gè)示例中，我們創(chuàng)建了一個(gè)定時(shí)器，設(shè)置1秒后觸發(fā)。然后，我們啟動(dòng)了5個(gè)并發(fā)任務(wù)，每個(gè)任務(wù)在定時(shí)器觸發(fā)后執(zhí)行。我們使用sync.WaitGroup來確保所有任務(wù)都完成后再繼續(xù)執(zhí)行后續(xù)代碼。

當(dāng)你運(yùn)行這個(gè)程序時(shí)，你會(huì)看到以下輸出：

Task 1 started
Task 2 started
Task 3 started
Task 4 started
Task 5 started
Task 1 finished
Task 2 finished
Task 3 finished
Task 4 finished
Task 5 finished
All tasks completed

這個(gè)示例展示了如何使用Go語言的Timer類型處理并發(fā)任務(wù)。你可以根據(jù)自己的需求修改這個(gè)示例，以適應(yīng)不同的場景。