Go в примерах: Набор обработчиков (Worker Pools)
|
В этом примере реализован набор обработчиков (worker pool) с помощью горутин и каналов. |
|
package main
|
|
import "fmt"
import "time"
|
|
|
С помощью этого обработчика запустим несколько
одновременых экземпляров. Эти обработчики будут получать
задачи из канала |
func worker(id int, jobs <-chan int, results chan<- int) {
for j := range jobs {
fmt.Println("worker", id, "processing job", j)
time.Sleep(time.Second)
results <- j * 2
}
}
|
func main() {
|
|
|
Для использования набора обработчиков нужно отправлять ему задачи и собирать результаты. Сделаем для этого 2 канала. |
jobs := make(chan int, 100)
results := make(chan int, 100)
|
|
Здесь запускается 3 обработчика, первоначально заблокированные, поскольку пока нет задач. |
for w := 1; w <= 3; w++ {
go worker(w, jobs, results)
}
|
|
Отправляем 9 |
for j := 1; j <= 9; j++ {
jobs <- j
}
close(jobs)
|
|
В конце собираем все результаты обработки. |
for a := 1; a <= 9; a++ {
<-results
}
}
|
|
Запущенная программа показывает, что выполняются 9 задач разными обработчиками. Эта программа тратит только примерно 3 секунды несмотря на общую работу в 9 секунд. Так как 3 обработчика работают одновременно. |
$ time go run worker-pools.go
worker 1 processing job 1
worker 2 processing job 2
worker 3 processing job 3
worker 1 processing job 4
worker 2 processing job 5
worker 3 processing job 6
worker 1 processing job 7
worker 2 processing job 8
worker 3 processing job 9
|
real 0m3.149s
|
Следующий пример: Ограничение скорости (Rate Limiting).