()
| 124 | } |
| 125 | |
| 126 | func (pool *WorkerPool) dispatch() { |
| 127 | for { |
| 128 | select { |
| 129 | case job := <-pool.jobs: |
| 130 | // handle job |
| 131 | todo := <-pool.pool |
| 132 | todo <- job |
| 133 | case <-pool.quit: |
| 134 | return |
| 135 | } |
| 136 | } |
| 137 | } |
| 138 | |
| 139 | //----------------------------------------------------------------------------- |
| 140 |