farn.run.utils.threading

Classes

JobQueue([maxsize])	Queue for jobs to be executed by worker threads.
Worker(job_queue)	Worker thread executing jobs from a job queue.