Paul Pan
6956fe4ee1
pkg/pool: task is now available to return interface{} as result
pkg/pool: use atomic instead of mutex
service/runner: ContainerRun will return metrics
25 lines
440 B
Go
25 lines
440 B
Go
package pool
|
|
|
|
import (
|
|
"sync"
|
|
)
|
|
|
|
type Worker struct {
|
|
id int
|
|
queue chan Task
|
|
pool *TaskPool // back reference to the pool
|
|
}
|
|
|
|
func NewWorker(id int, queue chan Task, pool *TaskPool) *Worker {
|
|
return &Worker{id: id, queue: queue, pool: pool}
|
|
}
|
|
|
|
func (w *Worker) Start(wg *sync.WaitGroup) {
|
|
defer wg.Done()
|
|
|
|
for task := range w.queue {
|
|
val, err := task.f()
|
|
w.pool.markTaskComplete(task.id, WaitBuf{Value: val, Error: err})
|
|
}
|
|
}
|