Login Register

multiprocessing.JoinableQueue.join()

join()

Block until all items in the queue have been gotten and processed.

The count of unfinished tasks goes up whenever an item is added to the queue. The count goes down whenever a consumer calls task_done() to indicate that the item was retrieved and all work on it is complete. When the count of unfinished tasks drops to zero, join() unblocks.

Links:

https://docs.python.org/3.5/library/multiprocessing.html#multiprocessing.JoinableQueue.join

doc_python

2016-10-07 17:37:41

Comments

Leave a Comment

Please login to continue.

Popular Articles

multiprocessing.JoinableQueue class multiprocessing.JoinableQueue([maxsize]) JoinableQueue, a Queue subclass, is a queue which additionally has task_done() and join() methods.

multiprocessing.JoinableQueue.task_done() task_done() Indicate that a formerly enqueued task is complete. Used by queue consumers. For each get() used to fetch a task, a subsequent call to

multiprocessing.Process.join() join([timeout]) If the optional argument timeout is None (the default), the method blocks until the process whose join() method is called terminat

multiprocessing.pool.Pool.join() join() Wait for the worker processes to exit. One must call close() or terminate() before using join().

multiprocessing.Queue.join_thread() join_thread() Join the background thread. This can only be used after close() has been called. It blocks until the background thread exits, ensuri