cpython

Commit Graph

Author	SHA1	Message	Date
Antoine Pitrou	f70401e842	Issue #14406 : Fix a race condition when using `concurrent.futures.wait(return_when=ALL_COMPLETED)`. Patch by Matt Joiner.	14 years ago
Antoine Pitrou	bdb1cf1ca5	Issue #12328 : Fix multiprocessing's use of overlapped I/O on Windows. 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.	14 years ago
Ross Lagerwall	66e2fb68ac	Issue #12364 : Fix a hang in concurrent.futures.ProcessPoolExecutor.	14 years ago
Florent Xicluna	04842a84c3	Remove unused or redundant imports in concurrent.futures and multiprocessing.	14 years ago
Antoine Pitrou	0b447957c7	Close the call queue in concurrent.futures.ProcessPoolExecutor when shutdown() is called, without waiting for the garbage collector to kick in.	15 years ago
Antoine Pitrou	dc19c24832	Silence spurious "broken pipe" tracebacks when shutting down a ProcessPoolExecutor.	15 years ago
Antoine Pitrou	d06a065a44	Fix potential resource leaks in concurrent.futures.ProcessPoolExecutor by joining all queues and processes when shutdown() is called.	15 years ago
Antoine Pitrou	1c405b3e60	Followup to 51c1f2cedb96 (and issue #12456 ): qsize() raises NotImplementedError on OS X, don't use it.	15 years ago
Antoine Pitrou	020436b0d4	Issue #12456 : fix a possible hang on shutdown of a concurrent.futures.ProcessPoolExecutor.	15 years ago
Antoine Pitrou	dd69649660	Issue #9205 : concurrent.futures.ProcessPoolExecutor now detects killed children and raises BrokenProcessPool in such a situation. Previously it would reliably freeze/deadlock.	15 years ago
Antoine Pitrou	b87a56a519	Fix typo in name of private function	15 years ago
Antoine Pitrou	b7877f203d	Issue #11815 : Use a light-weight SimpleQueue for the result queue in concurrent.futures.ProcessPoolExecutor.	15 years ago
Antoine Pitrou	27be5da831	Issue #11815 : Remove dead code in concurrent.futures (since a blocking Queue cannot raise queue.Empty).	15 years ago
Brian Quinlan	f007876bd6	Issue #11777 : Executor.map does not submit futures until iter.next() is called	15 years ago
Antoine Pitrou	c13d454e84	Issue #11635 : Don't use polling in worker threads and processes launched by concurrent.futures.	15 years ago
Brian Quinlan	142fad4b6b	Use WeakSets rather than manual pruning to prevent unbounded growth of dead thread references.	15 years ago
Martin v. Löwis	9f6d48ba4e	Issue #10798 : Reject supporting concurrent.futures if the system has too few POSIX semaphores.	15 years ago
Brian Quinlan	251cc846f3	Does not install a logging handler. Fixes issue 10626.	15 years ago
Georg Brandl	fb1720b0f5	Fix "seperate".	15 years ago
Brian Quinlan	3ec60183a4	Removes an inefficient spin loop in as_completed	15 years ago
Brian Quinlan	1e2ae4f054	Fixes 9903: test_concurrent_futures writes on stderr	16 years ago
Brian Quinlan	81c4d36928	Initial implementation of PEP 3148	16 years ago

25 Commits (fe8440aec00af5bc2e995aaad205efa2e693a364)