diff options
| author | Antoine Pitrou <solipsis@pitrou.net> | 2011-12-21 10:03:24 (GMT) |
|---|---|---|
| committer | Antoine Pitrou <solipsis@pitrou.net> | 2011-12-21 10:03:24 (GMT) |
| commit | de911b2915476938c66855d91df6fa4bbd77b39f (patch) | |
| tree | aba25854f48dd0b7f99ef21d5e86ab7c6ad5a8cb /Lib/multiprocessing/managers.py | |
| parent | 12f65d1fefde68ae142b96075917012a61cb8abf (diff) | |
| download | cpython-de911b2915476938c66855d91df6fa4bbd77b39f.zip cpython-de911b2915476938c66855d91df6fa4bbd77b39f.tar.gz cpython-de911b2915476938c66855d91df6fa4bbd77b39f.tar.bz2 | |
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 f42d353..5cae4c1 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' } |