multiprocessing.Queue.close()

close() Indicate that no more data will be put on this queue by the current process. The background thread will quit once it

2016-10-07 17:37:59
multiprocessing.managers.SyncManager.Event()

Event() Create a shared

2016-10-07 17:37:48
threading.Semaphore.acquire()

acquire(blocking=True, timeout=None) Acquire a semaphore. When invoked without arguments: if

2016-10-07 17:44:36
_thread.lock.acquire()

lock.acquire(waitflag=1, timeout=-1) Without any optional argument, this method acquires the lock unconditionally, if necessary

2016-10-07 17:48:51
multiprocessing.Process.daemon

daemon The process’s daemon flag, a Boolean value. This must be set before start() is called. The

2016-10-07 17:37:55
subprocess.TimeoutExpired

exception subprocess.TimeoutExpired Subclass of SubprocessError, raised when a timeout expires while waiting for

2016-10-07 17:43:39
threading.Barrier.wait()

wait(timeout=None) Pass the barrier. When all the threads party to the barrier have called this function, they are all released

2016-10-07 17:44:32
_thread.get_ident()

_thread.get_ident() Return the ‘thread identifier’ of the current thread. This is a nonzero integer. Its value has no direct

2016-10-07 17:48:50
multiprocessing.Barrier

class multiprocessing.Barrier(parties[, action[, timeout]]) A barrier object: a clone of

2016-10-07 17:37:33
multiprocessing.JoinableQueue.join()

join() Block until all items in the queue have been gotten and processed. The count of unfinished

2016-10-07 17:37:41