资 源 简 介
ThreadPool Component
The ThreadPool is a component in which other components can get jobs executed.
The API has three important functions:
ThreadPool(max_workers=5, kill_workers_after=3)
Constructor function
* max_workers is the maximum number of threads used in/by the pool.
* kill_workers_after is the number of seconds a worker should wait for jobs before being killed
add_job(function, args=None, return_callback=None)
function is the callable that defines the job
args is a list of arguments to the function
return_callback is called when the function has been performed.
shutdown(wait_for_workers_period = 1, clean_shutdown_reties = 5)
Blocks so no more jobs are accepted. Waits for all workers to punch out. When a call to this function returns the program can be terminated.
* wait_for_workers_period is the number of seconds to wait for workers to shutdown
* clean_shutdown_ret
