golangrange实现简单线程池

什么是 range

在golang中，range是一个非常有用的关键字。它用于遍历slice、map、string等数据结构，并且非常容易使用。

range的语法非常简单，格式为：

for index, value := range someSlice {
    //do something with index and value 
}

在这个例子中，我们使用range遍历了一个slice，并返回了每个元素的索引和值。

什么是线程池

线程池是一种用于优化多线程应用程序的技术。它的主要思想是在应用程序启动时创建一组线程，这些线程可以处理多个任务，并且在任务完成后可以自动复用。

通常情况下，创建和销毁线程会导致一定的开销，因此在多线程环境下使用线程池可以大大降低这种开销，提高系统性能。

使用golang range实现简单线程池

利用golang range的特性，我们可以快速实现一个简单的线程池。

首先，我们需要创建一个任务队列，并在程序启动时初始化一组goroutine池。

type Job struct {
    Payload interface{}
    Callback func(interface{})
}

type WorkerPool struct {
    Jobs        chan Job
    NumWorkers  int
    shutdown    chan bool
}

func NewWorkerPool(numWorkers int) *WorkerPool {
    wp := &WorkerPool{
        Jobs:        make(chan Job),
        NumWorkers:  numWorkers,
        shutdown:    make(chan bool),
    }

    for i := 0; i < numWorkers; i++ {
        go wp.startWorker()
    }

    return wp
}

在这段代码中，我们定义了一个Job结构体，包含一个Payload字段表示任务内容，以及一个Callback函数表示任务完成后的回调函数。

接着，我们定义了一个WorkerPool结构体，其中Jobs是一个channel用于存储任务；NumWorkers表示要创建的goroutine数量；shutdown是一个channel用于通知goroutine停止工作。

在NewWorkerPool函数中，我们初始化了一个WorkerPool，并且通过range循环等待接收任务，并将任务投递到goroutine池中处理。

func (wp *WorkerPool) startWorker() {
    for job := range wp.Jobs {
        job.Callback(job.Payload)
    }
}

func (wp *WorkerPool) Shutdown() {
    close(wp.Jobs)
    for i := 0; i < wp.NumWorkers; i++ {
        <-wp.shutdown
    }
}

func (wp *WorkerPool) AddJob(job Job) {
    wp.Jobs <- job
}

在startWorker函数中，我们用range获取工作池中的任务，并执行任务的回调函数。在Shutdown函数中，我们关闭Jobs channel，并循环等待每一个goroutine完成工作。在AddJob函数中，我们将任务投递到Jobs channel中。

使用golang range实现简单的线程池非常容易，而且非常适合处理大量的并发任务。这样可以降低应用程序的响应时间，并提高系统的可靠性和稳定性。