> # 協程 (捕獲異常 和 協程池) - Go 語言中的`goroutine`雖然相對于系統線程來說比較輕量級（初始棧大小僅`2KB`） - 但是在高并發量下的`goroutine`頻繁創建和銷毀對于性能損耗以及`GC`來說壓力也不小。充分將`goroutine`復用，減少`goroutine`的創建/銷毀的性能損耗，這便是`grpool`對`goroutine`進行池化封裝的目的 - https://goframe.org/pages/viewpage.action?pageId=1114246 >### WorkerPool 定義一個工作池結構體 ~~~ package main import ( "fmt" "sync" ) // WorkerPool 定義一個工作池結構體 type WorkerPool struct { maxWorkers int taskQueue chan func() wg sync.WaitGroup } // NewWorkerPool 創建一個新的工作池 func NewWorkerPool(maxWorkers int) *WorkerPool { return &WorkerPool{ maxWorkers: maxWorkers, taskQueue: make(chan func()), } } // Start 啟動工作池 func (wp *WorkerPool) Start() { for i := 0; i < wp.maxWorkers; i++ { go wp.worker() } } // worker 執行任務的工作者 goroutine func (wp *WorkerPool) worker() { for task := range wp.taskQueue { safeExecute(task) wp.wg.Done() } } // safeExecute 安全執行任務，捕獲異常 func safeExecute(task func()) { defer func() { if r := recover(); r != nil { fmt.Println("Recovered from panic:", r) } }() task() } // Submit 提交任務到工作池 func (wp *WorkerPool) Submit(task func()) { wp.wg.Add(1) wp.taskQueue <- task } // Wait 等待所有任務完成 func (wp *WorkerPool) Wait() { wp.wg.Wait() close(wp.taskQueue) } ~~~ >### 任務 ~~~ package main import ( "fmt" "time" ) func main() { n := 0 //處理任務一 for i := 0; i < 10; i++ { SafeGo(func() { for { n += 1 time.Sleep(time.Second) } }) } SafeGo(func() { for { fmt.Println(n) time.Sleep(time.Second * 3) } }) time.Sleep(time.Hour) } var pool *WorkerPool func init() { pool = NewWorkerPool(200) pool.Start() } func SafeGo(f func()) { pool.Submit(f) } ~~~