GO workPool的線程池實現(xiàn)
Go語言中的線程池是一種用于管理并發(fā)執(zhí)行任務(wù)的設(shè)計模式。
線程池的主要目的是減少創(chuàng)建和銷毀線程的開銷，提高系統(tǒng)性能。 在Go語言中，線程池通常使用goroutine和channel來實現(xiàn)。
以下是一個簡單的Go線程池實現(xiàn)：
package main
import (
"fmt"
"sync"
)
type Job func()
type Worker struct {
JobQueue chan Job
}
func NewWorker() Worker {
return Worker{JobQueue: make(chan Job)}
}
func (w Worker) Run(wg *sync.WaitGroup) {
go func() {
for job := range w.JobQueue {
job()
wg.Done()
}
}()
}
type Pool struct {
JobQueue chan Job
WorkerQueue chan chan Job
}
func NewPool(maxWorkers int) *Pool {
workerQueue := make(chan chan Job, maxWorkers)
jobQueue := make(chan Job)
return &Pool{JobQueue: jobQueue, WorkerQueue: workerQueue}
}
func (p *Pool) Run() {
for i := 0; i < cap(p.WorkerQueue); i++ {
worker := NewWorker()
worker.Run(&sync.WaitGroup{})
p.WorkerQueue <- worker.JobQueue
}
go func() {
for job := range p.JobQueue {
workerJobQueue := <-p.WorkerQueue
workerJobQueue <- job
}
}()
}
func main() {
pool := NewPool(5)
pool.Run()
wg := sync.WaitGroup{}
wg.Add(10)
for i := 0; i < 10; i++ {
job := func() {
fmt.Println("Executing job")
}
pool.JobQueue <- job
}
wg.Wait()
}說明
在這個例子中，我們創(chuàng)建了 Worker結(jié)構(gòu)體，它包含一個JobQueue通道，用于接收任務(wù)。 NewWorker函數(shù)用于創(chuàng)建一個新的Worker實例。 Run方法啟動一個goroutine，監(jiān)聽JobQueue通道，當(dāng)有任務(wù)到來時，執(zhí)行任務(wù)并通知WaitGroup。
Pool結(jié)構(gòu)體包含一個JobQueue通道和一個WorkerQueue通道。 JobQueue用于接收任務(wù)，WorkerQueue用于存儲空閑的Worker。 NewPool函數(shù)用于創(chuàng)建一個新的Pool實例。 Run方法啟動指定數(shù)量的 Worker并將它們添加到 WorkerQueue中。然后啟動一個goroutine，監(jiān)聽 JobQueue通道，當(dāng)有任務(wù)到來時，從 WorkerQueue中取出一個空閑的 Worker，將任務(wù)分配給它。
在main函數(shù)中，我們創(chuàng)建一個包含5個Worker的線程池，并向線程池提交10個任務(wù)。 使用WaitGroup來等待所有任務(wù)完成。
小結(jié)有需要的小伙伴可以加以修改使用
到此這篇關(guān)于GO workPool的線程池實現(xiàn)的文章就介紹到這了,更多相關(guān)GO workPool線程池內(nèi)容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！
相關(guān)文章
Go語言服務(wù)器開發(fā)之簡易TCP客戶端與服務(wù)端實現(xiàn)方法
這篇文章主要介紹了Go語言服務(wù)器開發(fā)之簡易TCP客戶端與服務(wù)端實現(xiàn)方法,實例分析了基于Go語言實現(xiàn)的簡易服務(wù)器的TCP客戶端與服務(wù)器端實現(xiàn)技巧,需要的朋友可以參考下2015-02-02
在 Go 語言中,map 是一種內(nèi)置的關(guān)聯(lián)數(shù)據(jù)結(jié)構(gòu)類型,由一組無序的鍵值對組成,每個鍵都是唯一的,并與一個對應(yīng)的值相關(guān)聯(lián),本文將詳細(xì)介紹哪些類型的變量可以作為 map 的鍵,并通過實例進(jìn)行說明,感興趣的朋友可以參考下2024-01-01
在Go編程中,上下文（context）是一個非常重要的概念,它包含了與請求相關(guān)的信息,本文主要來和大家討論一下如何在并發(fā)計算中使用上下文,感興趣的可以了解下2024-02-02
fasthttp?是一個使用?Go?語言開發(fā)的?HTTP?包,主打高性能,針對?HTTP?請求響應(yīng)流程中的?hot?path?代碼進(jìn)行了優(yōu)化,下面我們就來介紹go語言fasthttp使用實例小結(jié),感興趣的朋友跟隨小編一起看看吧2024-03-03
Go語言基礎(chǔ)語法之結(jié)構(gòu)體及方法詳解
結(jié)構(gòu)體類型可以用來保存不同類型的數(shù)據(jù)，也可以通過方法的形式來聲明它的行為。本文將介紹go語言中的結(jié)構(gòu)體和方法，以及“繼承”的實現(xiàn)方法2021-09-09
分布式鏈路追蹤作為解決分布式應(yīng)用可觀測問題的重要技術(shù)，愈發(fā)成為分布式應(yīng)用不可缺少的基礎(chǔ)設(shè)施，本文將詳細(xì)介紹分布式鏈路的核心概念、架構(gòu)原理和相關(guān)開源標(biāo)準(zhǔn)協(xié)議，并分享我們在實現(xiàn)無侵入 Go 采集 Sdk 方面的一些實踐,需要的朋友可以參考下2022-06-06
這篇文章主要介紹了golang1.16新特性速覽,本文給大家介紹的非常詳細(xì)，對大家的學(xué)習(xí)或工作具有一定的參考借鑒價值，需要的朋友可以參考下2021-02-02
這篇文章主要介紹了golang日志框架之logrus的使用，文中通過示例代碼介紹的非常詳細(xì)，對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價值，需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧2019-08-08
在日常開發(fā)中,緩存是提高系統(tǒng)性能的重要手段,LRU緩存是一種基于“最近最少使用”策略的緩存系統(tǒng),其目的是在空間受限的情況下保留最新、最常用的數(shù)據(jù),本文將詳細(xì)講解如何使用?Go?語言實現(xiàn)一個?LRU?緩存,需要的朋友可以參考下2024-11-11
Go語言的標(biāo)準(zhǔn)庫為開發(fā)者提供了豐富且高效的工具,涵蓋了從網(wǎng)絡(luò)編程到文件操作等各個方面,然而,標(biāo)準(zhǔn)庫雖好,使用不當(dāng)卻可能適得其反,正所謂"工欲善其事,必先利其器",本文將深入剖析Go標(biāo)準(zhǔn)庫使用中的常見錯誤,幫助開發(fā)者避開這些坑,寫出更加健壯的代碼2025-04-04