multiprocessing.Connection.recv_bytes_into()

recv_bytes_into(buffer[, offset]) Read into buffer a complete message of byte data sent from the other end of the connection

2016-10-07 17:37:38
concurrent.futures.Future.done()

done() Return True if the call was successfully cancelled or finished running.

2016-10-07 17:29:07
concurrent.futures.Future.cancel()

cancel() Attempt to cancel the call. If the call is currently being executed and cannot be cancelled then the method will return

2016-10-07 17:29:07
threading.stack_size()

threading.stack_size([size]) Return the thread stack size used when creating new threads. The optional size argument

2016-10-07 17:44:37
multiprocessing.BoundedSemaphore

class multiprocessing.BoundedSemaphore([value]) A bounded semaphore object: a close analog of

2016-10-07 17:37:33
concurrent.futures.Executor.map()

map(func, *iterables, timeout=None, chunksize=1) Equivalent to

2016-10-07 17:29:06
multiprocessing.pool.Pool.map()

map(func, iterable[, chunksize]) A parallel equivalent of the

2016-10-07 17:37:54
multiprocessing.Queue

class multiprocessing.Queue([maxsize]) Returns a process shared queue implemented using a pipe and a few locks/semaphores. When

2016-10-07 17:37:59
sched.scheduler.run()

scheduler.run(blocking=True) Run all scheduled events. This method will wait (using the delayfunc() function passed

2016-10-07 17:41:31
multiprocessing.get_all_start_methods()

multiprocessing.get_all_start_methods() Returns a list of the supported start methods, the first of which is the default. The

2016-10-07 17:37:40