v2.util #

fn WorkerPool.new[T, Y]() &WorkerPool[T, Y]

fn (mut wp WorkerPool[T, Y]) add_worker(t thread)

fn (mut wp WorkerPool[T, Y]) active_jobs() int

fn (mut wp WorkerPool[T, Y]) get_job() !T

fn (mut wp WorkerPool[T, Y]) push_result(result Y)

fn (mut wp WorkerPool[T, Y]) job_done()

fn (mut wp WorkerPool[T, Y]) queue_job(job T)

fn (mut wp WorkerPool[T, Y]) queue_jobs(jobs []T)

fn (mut wp WorkerPool[T, Y]) wait_for_results() []Y

struct WorkerPool[T, Y] {
mut:
	workers   []thread
	queue_len shared SharedIntWorkaround
	ch_in     chan T
	ch_out    chan Y
}