溫馨提示×

Go語言定時器怎樣處理并發任務

小樊
85
2024-10-31 00:20:43
欄目: 編程語言

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

下面是一個簡單的示例,展示了如何使用Timersync.WaitGroup處理并發任務:

package main

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

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

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

func main() {
	var wg sync.WaitGroup
	timer := time.NewTimer(1 * time.Second) // 創建一個定時器,1秒后觸發

	for i := 1; i <= 5; i++ {
		wg.Add(1) // 為每個任務增加一個計數
		go task(i, &wg, timer) // 啟動并發任務
	}

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

在這個示例中,我們創建了一個定時器,設置1秒后觸發。然后,我們啟動了5個并發任務,每個任務在定時器觸發后執行。我們使用sync.WaitGroup來確保所有任務都完成后再繼續執行后續代碼。

當你運行這個程序時,你會看到以下輸出:

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

這個示例展示了如何使用Go語言的Timer類型處理并發任務。你可以根據自己的需求修改這個示例,以適應不同的場景。

0
亚洲午夜精品一区二区_中文无码日韩欧免_久久香蕉精品视频_欧美主播一区二区三区美女