91超碰碰碰碰久久久久久综合_超碰av人澡人澡人澡人澡人掠_国产黄大片在线观看画质优化_txt小说免费全本

溫馨提示×

golang線程池怎么實現

小億
129
2023-10-26 18:28:28
欄目: 編程語言

在Go語言中,可以使用goroutinechannel來實現線程池。下面是一個簡單的線程池實現示例:

package main

import (
	"fmt"
	"sync"
)

type ThreadPool struct {
	workerNum int           // 工作線程數量
	taskQueue chan func()  // 任務隊列
	wg        sync.WaitGroup // 等待所有任務完成
}

func NewThreadPool(workerNum int) *ThreadPool {
	return &ThreadPool{
		workerNum: workerNum,
		taskQueue: make(chan func()),
	}
}

func (tp *ThreadPool) Start() {
	for i := 0; i < tp.workerNum; i++ {
		go tp.worker()
	}
}

func (tp *ThreadPool) worker() {
	for task := range tp.taskQueue {
		task()
		tp.wg.Done()
	}
}

func (tp *ThreadPool) AddTask(task func()) {
	tp.wg.Add(1)
	tp.taskQueue <- task
}

func (tp *ThreadPool) Wait() {
	tp.wg.Wait()
}

func main() {
	// 創建線程池
	pool := NewThreadPool(3)
	// 啟動線程池
	pool.Start()

	// 添加任務到線程池
	for i := 0; i < 10; i++ {
		taskNum := i
		pool.AddTask(func() {
			fmt.Printf("Task %d is running\n", taskNum)
		})
	}

	// 等待所有任務完成
	pool.Wait()
}

在上面的示例中,ThreadPool結構體表示線程池,包含workerNum表示工作線程的數量,taskQueue表示任務隊列,wgsync.WaitGroup用于等待所有任務完成。

NewThreadPool函數用于創建一個新的線程池,Start方法啟動線程池中的工作線程,worker方法用于執行任務,AddTask方法用于往線程池中添加任務,Wait方法用于等待所有任務完成。

main函數中,創建一個線程池并啟動,然后循環添加任務到線程池中,最后調用Wait方法等待所有任務完成。

當運行上述代碼時,你會看到輸出結果中的任務是并發執行的,最多同時執行3個任務,這就是線程池的作用。

0
安仁县| 石柱| 浙江省| 赤峰市| 霍林郭勒市| 嘉定区| 班玛县| 鹤山市| 卢湾区| SHOW| 达州市| 宁夏| 承德县| 靖宇县| 舟曲县| 襄汾县| 图们市| 离岛区| 抚远县| 松原市| 武宣县| 贵州省| 凯里市| 青川县| 岚皋县| 蒙山县| 长宁县| 咸阳市| 武义县| 夏邑县| 十堰市| 资兴市| 东港市| 平果县| 阿尔山市| 江达县| 正安县| 邻水| 策勒县| 招远市| 台湾省|