为什么要重用线程

减少开销：线程的创建和销毁涉及内存分配和释放，以及相关系统资源的初始化和清理，这些都是有时间和空间开销的。通过重用线程，可以避免这些开销，从而提高系统效率。

提高响应速度：现成的空闲线程可以立即被分配来处理新的任务，避免了线程创建的延时，从而提高了系统的响应速度。

降低内存碎片化：频繁的内存分配和释放可能导致内存碎片化，影响内存利用率。线程重用通过减少内存分配和释放频率，有助于降低内存碎片化。

节约系统资源：每个线程的创建都会占用一定的系统资源。线程重用可以节约这些资源，提升系统的扩展性和稳定性。

package main

import (
	"fmt"
	"sync"
)

// 任务
type Task struct {
	id int
}

// worker函数，处理任务
func worker(id int, tasks <-chan Task, wg *sync.WaitGroup) {
	defer wg.Done()  // 在函数退出时，通知WaitGroup一个任务已完成

	for task := range tasks {  // 循环从任务通道接收任务并处理
		fmt.Printf("Worker %d processing task %d\n", id, task.id)
	}
}

func main() {
	const numWorkers = 5  // 定义worker数量
	const numTasks = 10   // 定义任务数量

	tasks := make(chan Task, numTasks)  // 创建任务通道
	var wg sync.WaitGroup  // 创建一个WaitGroup以等待所有任务完成

	// 启动worker goroutines
	for i := 1; i <= numWorkers; i++ {
		wg.Add(1)  // 为每个worker增加一个任务计数
		go worker(i, tasks, &wg)  // 启动worker
	}

	// 将任务发送到任务通道
	for i := 1; i <= numTasks; i++ {
		tasks <- Task{id: i}
	}

	close(tasks)  // 关闭任务通道，通知所有worker没有更多任务
	wg.Wait()     // 等待所有任务完成
}