Commit message (Collapse) | Author | Age | Files | Lines | |
---|---|---|---|---|---|
* | #15015: Fix accessing an non-existing attribute. | Brian Quinlan | 2012-06-11 | 1 | -2/+2 |
| | |||||
* | Issue #14406: Fix a race condition when using ↵ | Antoine Pitrou | 2012-03-31 | 1 | -3/+5 |
|\ | | | | | | | | | | | `concurrent.futures.wait(return_when=ALL_COMPLETED)`. Patch by Matt Joiner. | ||||
| * | Issue #14406: Fix a race condition when using ↵ | Antoine Pitrou | 2012-03-31 | 1 | -3/+5 |
| | | | | | | | | | | | | `concurrent.futures.wait(return_when=ALL_COMPLETED)`. Patch by Matt Joiner. | ||||
* | | Issue #12328: Fix multiprocessing's use of overlapped I/O on Windows. | Antoine Pitrou | 2012-03-05 | 1 | -4/+8 |
| | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | 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. | ||||
* | | Merge with 3.2 for #12364. | Ross Lagerwall | 2012-01-08 | 1 | -3/+0 |
|\ \ | |/ | |||||
| * | Issue #12364: Fix a hang in concurrent.futures.ProcessPoolExecutor. | Ross Lagerwall | 2012-01-08 | 1 | -6/+1 |
| | | |||||
| * | Close the call queue in concurrent.futures.ProcessPoolExecutor when | Antoine Pitrou | 2011-07-16 | 1 | -0/+1 |
| | | | | | | | | shutdown() is called, without waiting for the garbage collector to kick in. | ||||
* | | Remove unused or redundant imports in concurrent.futures and multiprocessing. | Florent Xicluna | 2011-11-11 | 3 | -4/+2 |
| | | |||||
* | | Silence spurious "broken pipe" tracebacks when shutting down a ↵ | Antoine Pitrou | 2011-07-15 | 1 | -4/+7 |
| | | | | | | | | ProcessPoolExecutor. | ||||
* | | Fix potential resource leaks in concurrent.futures.ProcessPoolExecutor | Antoine Pitrou | 2011-07-15 | 1 | -1/+4 |
| | | | | | | | | by joining all queues and processes when shutdown() is called. | ||||
* | | Followup to 51c1f2cedb96 (and issue #12456): | Antoine Pitrou | 2011-07-03 | 1 | -10/+10 |
| | | | | | | | | qsize() raises NotImplementedError on OS X, don't use it. | ||||
* | | Issue #12456: fix a possible hang on shutdown of a ↵ | Antoine Pitrou | 2011-07-02 | 1 | -9/+21 |
| | | | | | | | | concurrent.futures.ProcessPoolExecutor. | ||||
* | | Issue #9205: concurrent.futures.ProcessPoolExecutor now detects killed | Antoine Pitrou | 2011-06-08 | 1 | -31/+74 |
| | | | | | | | | | | children and raises BrokenProcessPool in such a situation. Previously it would reliably freeze/deadlock. | ||||
* | | Fix typo in name of private function | Antoine Pitrou | 2011-05-03 | 1 | -7/+7 |
|\ \ | |/ | |||||
| * | Fix typo in name of private function | Antoine Pitrou | 2011-05-03 | 1 | -7/+7 |
| | | |||||
* | | Issue #11815: Use a light-weight SimpleQueue for the result queue in ↵ | Antoine Pitrou | 2011-04-12 | 1 | -2/+3 |
| | | | | | | | | concurrent.futures.ProcessPoolExecutor. | ||||
* | | Issue #11815: Remove dead code in concurrent.futures (since a blocking Queue | Antoine Pitrou | 2011-04-12 | 2 | -52/+29 |
|\ \ | |/ | | | | | cannot raise queue.Empty). | ||||
| * | Issue #11815: Remove dead code in concurrent.futures (since a blocking Queue | Antoine Pitrou | 2011-04-12 | 2 | -52/+29 |
| | | | | | | | | cannot raise queue.Empty). | ||||
* | | Issue #11777: Executor.map does not submit futures until iter.next() is called | Brian Quinlan | 2011-04-07 | 1 | -9/+13 |
|/ | |||||
* | Issue #11635: Don't use polling in worker threads and processes launched by | Antoine Pitrou | 2011-03-26 | 2 | -79/+93 |
| | | | | concurrent.futures. | ||||
* | Issue #10798: Reject supporting concurrent.futures if the system has | Martin v. Löwis | 2011-01-03 | 1 | -0/+26 |
| | | | | too few POSIX semaphores. | ||||
* | Does not install a logging handler. Fixes issue 10626. | Brian Quinlan | 2010-12-28 | 1 | -2/+0 |
| | |||||
* | Fix "seperate". | Georg Brandl | 2010-12-09 | 1 | -1/+1 |
| | |||||
* | Removes an inefficient spin loop in as_completed | Brian Quinlan | 2010-11-17 | 1 | -6/+35 |
| | |||||
* | Fixes 9903: test_concurrent_futures writes on stderr | Brian Quinlan | 2010-10-06 | 1 | -3/+2 |
| | |||||
* | Initial implementation of PEP 3148 | Brian Quinlan | 2010-09-18 | 4 | -0/+1032 |