
Sign up to save your podcasts
Or


Go's worker queue pattern:
type WorderPool struct {
queue chan int
}
func (wp *WorkerPool) start() {
for i := 0; i < 500; i++ {
go funcIO {
for id := range wp.queue {
doSomething(id)
}
}()
}
}
func (wp *WorkerPool) add(id int) {
wp.queue <- id
}
Best way to show support for the pod is by sharing it around and buying my course.
By Dominic St-Pierre3.8
66 ratings
Go's worker queue pattern:
type WorderPool struct {
queue chan int
}
func (wp *WorkerPool) start() {
for i := 0; i < 500; i++ {
go funcIO {
for id := range wp.queue {
doSomething(id)
}
}()
}
}
func (wp *WorkerPool) add(id int) {
wp.queue <- id
}
Best way to show support for the pod is by sharing it around and buying my course.

271 Listeners

383 Listeners

289 Listeners

626 Listeners

153 Listeners

585 Listeners

289 Listeners

988 Listeners

190 Listeners

182 Listeners

64 Listeners

142 Listeners

62 Listeners

16 Listeners

64 Listeners