| Commit message (Collapse) | Author | Age | Files | Lines |
| |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
| |
Also, add a multiprocessing.connection.wait(rlist, timeout=None) function
for polling multiple objects at once. Patch by sbt.
Complete changelist from sbt's patch:
* Adds a wait(rlist, timeout=None) function for polling multiple
objects at once. On Unix this is just a wrapper for
select(rlist, [], [], timeout=None).
* Removes use of the SentinelReady exception and the sentinels argument
to certain methods. concurrent.futures.process has been changed to
use wait() instead of SentinelReady.
* Fixes bugs concerning PipeConnection.poll() and messages of zero
length.
* Fixes PipeListener.accept() to call ConnectNamedPipe() with
overlapped=True.
* Fixes Queue.empty() and SimpleQueue.empty() so that they are
threadsafe on Windows.
* Now PipeConnection.poll() and wait() will not modify the pipe except
possibly by consuming a zero length message. (Previously poll()
could consume a partial message.)
* All of multiprocesing's pipe related blocking functions/methods are
now interruptible by SIGINT on Windows.
|
| |\ |
|
| | | |
|
| | |
| |
| |
| | |
shutdown() is called, without waiting for the garbage collector to kick in.
|
| | | |
|
| | |
| |
| |
| | |
ProcessPoolExecutor.
|
| | |
| |
| |
| | |
by joining all queues and processes when shutdown() is called.
|
| | |
| |
| |
| | |
qsize() raises NotImplementedError on OS X, don't use it.
|
| | |
| |
| |
| | |
concurrent.futures.ProcessPoolExecutor.
|
| | |
| |
| |
| |
| | |
children and raises BrokenProcessPool in such a situation. Previously it
would reliably freeze/deadlock.
|
| |\ \
| |/ |
|
| | | |
|
| |/
|
|
| |
concurrent.futures.ProcessPoolExecutor.
|
| |
|
|
| |
cannot raise queue.Empty).
|
| |
|
|
| |
concurrent.futures.
|
| |
|
|
| |
too few POSIX semaphores.
|
| | |
|
| |
|