diff options
| author | Antoine Pitrou <solipsis@pitrou.net> | 2011-12-21 11:03:24 +0100 |
|---|---|---|
| committer | Antoine Pitrou <solipsis@pitrou.net> | 2011-12-21 11:03:24 +0100 |
| commit | 56ec2a8ca7b4c9c27b6714cb3f82e13030e0b240 (patch) | |
| tree | afc071d3e781c6c35a02bf14d17598af5678e636 /Lib/multiprocessing/managers.py | |
| parent | a4ce02bfca9a04427ec63e8e1134e2225dcf27cb (diff) | |
| download | cpython-56ec2a8ca7b4c9c27b6714cb3f82e13030e0b240.tar.gz | |
Issue #12708: Add starmap() and starmap_async() methods (similar to itertools.starmap()) to multiprocessing.Pool.
Patch by Hynek Schlawack.
Diffstat (limited to 'Lib/multiprocessing/managers.py')
| -rw-r--r-- | Lib/multiprocessing/managers.py | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/Lib/multiprocessing/managers.py b/Lib/multiprocessing/managers.py index f42d353f0d..5cae4c1548 100644 --- a/Lib/multiprocessing/managers.py +++ b/Lib/multiprocessing/managers.py @@ -1066,11 +1066,12 @@ ArrayProxy = MakeProxyType('ArrayProxy', ( PoolProxy = MakeProxyType('PoolProxy', ( 'apply', 'apply_async', 'close', 'imap', 'imap_unordered', 'join', - 'map', 'map_async', 'terminate' + 'map', 'map_async', 'starmap', 'starmap_async', 'terminate' )) PoolProxy._method_to_typeid_ = { 'apply_async': 'AsyncResult', 'map_async': 'AsyncResult', + 'starmap_async': 'AsyncResult', 'imap': 'Iterator', 'imap_unordered': 'Iterator' } |