summaryrefslogtreecommitdiffstats
path: root/Lib/multiprocessing
Commit message (Collapse)AuthorAgeFilesLines
* Issue #14753: Make multiprocessing treat negative timeouts as it did in 3.2Richard Oudkerk2012-05-103-27/+4
| | | | | | | | In Python 3.2 and earlier, Process.join() and Connection.poll() treated negative timeouts as zero timeouts. Earlier versions from the 3.3 line of development treat them as infinite timeouts. The patch reverts to the old behaviour.
* Make AcquirerProxy.acquire() support timeout argumentRichard Oudkerk2012-05-061-2/+3
|
* Fix for Issue 14725 for 3.3 branch.Richard Oudkerk2012-05-051-9/+17
|
* Fix dangling warning for test_multiprocessingRichard Oudkerk2012-05-031-1/+4
|
* Mark multiprocessing files with "Licensed to PSF under a Contributor Agreement"Richard Oudkerk2012-04-3012-312/+12
| | | | instead of BSD licence.
* Issue #14666: stop multiprocessing's resource-sharing thread after the tests ↵Antoine Pitrou2012-04-271-1/+28
| | | | | | | | are done. Also, block delivery of signals to that thread. Patch by Richard Oudkerk. This will hopefully fix sporadic freezes on the FreeBSD 9.0 buildbot.
* Issue #4892: multiprocessing Connections can now be transferred over ↵Antoine Pitrou2012-04-244-159/+203
| | | | | | multiprocessing Connections. Patch by Richard Oudkerk (sbt).
* Issue #11750: The Windows API functions scattered in the _subprocess andAntoine Pitrou2012-04-184-84/+83
| | | | | _multiprocessing.win32 modules now live in a single module "_winapi". Patch by sbt.
* Issue #14087: multiprocessing: add Condition.wait_for(). Patch by sbt.Charles-François Natali2012-04-172-0/+38
|
* Issue #14522: Avoid duplicating socket handles in multiprocessing.connection.Antoine Pitrou2012-04-071-12/+3
| | | | Patch by sbt.
* Issue #14482: Raise a ValueError, not a NameError, when trying to createAntoine Pitrou2012-04-031-0/+4
|\ | | | | | | | | a multiprocessing Client or Listener with an AF_UNIX type address under Windows. Patch by Popa Claudiu.
| * Issue #14482: Raise a ValueError, not a NameError, when trying to createAntoine Pitrou2012-04-031-0/+4
| | | | | | | | | | a multiprocessing Client or Listener with an AF_UNIX type address under Windows. Patch by Popa Claudiu.
* | Issue #14151: Raise a ValueError, not a NameError, when trying to createAntoine Pitrou2012-04-011-0/+9
|\ \ | |/ | | | | | | a multiprocessing Client or Listener with an AF_PIPE type address under non-Windows platforms. Patch by Popa Claudiu.
| * Issue #14151: Raise a ValueError, not a NameError, when trying to createAntoine Pitrou2012-04-011-0/+9
| | | | | | | | | | a multiprocessing Client or Listener with an AF_PIPE type address under non-Windows platforms. Patch by Popa Claudiu.
* | Issue #14335: multiprocessing's custom Pickler subclass now inherits from ↵Antoine Pitrou2012-03-161-9/+9
| | | | | | | | | | | | the C-accelerated implementation. Patch by sbt.
* | Issue #12328: Fix multiprocessing's use of overlapped I/O on Windows.Antoine Pitrou2012-03-052-116/+217
| | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | 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.
* | Issue #11836: document and expose multiprocessing.SimpleQueueSandro Tosi2012-02-151-1/+8
|\ \ | |/
| * Issue #8184: Fix a potential file descriptor leak when aCharles-François Natali2012-02-041-4/+8
| | | | | | | | multiprocessing.Connection socket can't be bound.
* | Issue #8184: multiprocessing: On Windows, don't set SO_REUSEADDR on ConnectionCharles-François Natali2012-02-081-3/+8
| | | | | | | | | | sockets, and set FILE_FLAG_FIRST_PIPE_INSTANCE on named pipes, to make sure two listeners can't bind to the same socket/pipe (or any existing socket/pipe).
* | Issue #8184: Fix a potential file descriptor leak when aCharles-François Natali2012-02-041-4/+8
| | | | | | | | multiprocessing.Connection socket can't be bound.
* | Issue #13812: When a multiprocessing Process child raises an exception, ↵Antoine Pitrou2012-01-272-5/+4
|\ \ | |/ | | | | flush stderr after printing the exception traceback.
| * Issue #13812: When a multiprocessing Process child raises an exception, ↵Antoine Pitrou2012-01-272-5/+4
| | | | | | | | flush stderr after printing the exception traceback.
* | Issue #13565: Increase multiprocessing's server socket backlog, to avoidCharles-François Natali2011-12-231-1/+1
|\ \ | |/ | | | | dropped connections in case of simultaneous connection requests.
| * Issue #13565: Increase multiprocessing's server socket backlog, to avoidCharles-François Natali2011-12-231-1/+1
| | | | | | | | dropped connections in case of simultaneous connection requests.
* | Issue #12708: Add starmap() and starmap_async() methods (similar to ↵Antoine Pitrou2011-12-212-3/+32
| | | | | | | | | | | | itertools.starmap()) to multiprocessing.Pool. Patch by Hynek Schlawack.
* | Issue #13215: multiprocessing.Connection: don't hammer the remote end withCharles-François Natali2011-11-191-15/+1
| | | | | | | | retries in case of ECONNREFUSED.
* | Remove unused or redundant imports in concurrent.futures and multiprocessing.Florent Xicluna2011-11-119-24/+5
| |
* | Issue #13373: multiprocessing.Queue.get() could sometimes block indefinitelyAntoine Pitrou2011-11-091-1/+5
|\ \ | |/ | | | | when called with a timeout. Patch by Arnaud Ysmal.
| * Issue #13373: multiprocessing.Queue.get() could sometimes block indefinitelyAntoine Pitrou2011-11-091-1/+5
| | | | | | | | when called with a timeout. Patch by Arnaud Ysmal.
* | Merge 3.2Florent Xicluna2011-10-282-3/+3
|\ \ | |/
| * Closes #13258: Use callable() built-in in the standard library.Florent Xicluna2011-10-282-3/+3
| |
* | Issue #10332: multiprocessing: fix a race condition when a Pool is closedCharles-François Natali2011-10-241-1/+5
|\ \ | |/ | | | | before all tasks have completed.
| * Issue #10332: multiprocessing: fix a race condition when a Pool is closedCharles-François Natali2011-10-241-1/+5
| | | | | | | | before all tasks have completed.
* | Use InterruptedError instead of checking for EINTRAntoine Pitrou2011-10-231-6/+3
| |
* | Merge with 3.2.Ezio Melotti2011-10-191-1/+1
|\ \ | |/
| * Remove duplication.Ezio Melotti2011-10-191-1/+1
| |
* | PEP 3151 / issue #12555: reworking the OS and IO exception hierarchy.Antoine Pitrou2011-10-121-4/+4
| |
* | Issue #12981: rewrite multiprocessing_{sendfd,recvfd} in Python.Charles-François Natali2011-09-241-3/+18
| |
* | Issue #12996: multiprocessing.connection: transmit the header in network byteCharles-François Natali2011-09-201-2/+2
| | | | | | | | order (endpoints machines can have different endianness).
* | Remove indirection in threading (issue #10968).Éric Araujo2011-07-271-12/+1
| | | | | | | | | | | | | | | | | | | | | | | | The public names (Thread, Condition, etc.) used to be factory functions returning instances of hidden classes (_Thread, _Condition, etc.), because (if Guido recalls correctly) this code pre-dates the ability to subclass extension types. It is now possible to inherit from Thread and other classes, without having to import the private underscored names like multiprocessing did. A doc update will follow: a patch is under discussion on the issue.
* | Fix test_multiprocessing failure under Windows.Antoine Pitrou2011-07-201-2/+2
| | | | | | | | (followup to dfaa3a149a92)
* | Silence spurious "broken pipe" tracebacks when shutting down a ↵Antoine Pitrou2011-07-151-2/+7
| | | | | | | | ProcessPoolExecutor.
* | Issue #12573: Add resource checks for dangling Thread and Process objects.Antoine Pitrou2011-07-151-0/+5
|\ \ | |/
| * Issue #12573: Add resource checks for dangling Thread and Process objects.Antoine Pitrou2011-07-151-0/+5
| |
* | Add commentAntoine Pitrou2011-07-081-0/+2
| |
* | Rebind locally the globals which can be looked up at shutdownAntoine Pitrou2011-07-082-7/+11
| | | | | | | | (to avoid the warnings seen on a buildbot)
* | Merge issue #12352: Fix a deadlock in multiprocessing.Heap when a block isCharles-François Natali2011-07-021-6/+33
|\ \ | |/ | | | | freed by the garbage collector while the Heap lock is held.
| * Merge issue #12352: Fix a deadlock in multiprocessing.Heap when a block isCharles-François Natali2011-07-021-6/+33
| |\ | | | | | | | | | freed by the garbage collector while the Heap lock is held.
| | * Issue #12352: Fix a deadlock in multiprocessing.Heap when a block is freed byCharles-François Natali2011-07-021-6/+33
| | | | | | | | | | | | the garbage collector while the Heap lock is held.
* | | (merge 3.2) Issue #12285: multiprocessing.Pool() raises a ValueError if theVictor Stinner2011-06-201-0/+2
|\ \ \ | |/ / | | | | | | number of processes if negative or null.