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 // jobs queued but not yet completed
	total_expected shared SharedIntWorkaround // total results expected
	ch_in          chan T
	ch_out         chan Y
}