diff options
| author | Antoine Pitrou <solipsis@pitrou.net> | 2011-05-03 14:35:43 (GMT) |
|---|---|---|
| committer | Antoine Pitrou <solipsis@pitrou.net> | 2011-05-03 14:35:43 (GMT) |
| commit | 441f935228e1c2f15d3694221cdb0524de2abe0f (patch) | |
| tree | 2416501f9f0fc504419f558c6c6d9076cc0dd79d /Lib/concurrent/futures | |
| parent | d0e516db50376ab0fd729c42bafda3e5a6225b94 (diff) | |
| parent | b87a56a51954f470fa864118793cee97c04dca18 (diff) | |
| download | cpython-441f935228e1c2f15d3694221cdb0524de2abe0f.zip cpython-441f935228e1c2f15d3694221cdb0524de2abe0f.tar.gz cpython-441f935228e1c2f15d3694221cdb0524de2abe0f.tar.bz2 | |
Fix typo in name of private function
Diffstat (limited to 'Lib/concurrent/futures')
| -rw-r--r-- | Lib/concurrent/futures/process.py | 14 |
1 files changed, 7 insertions, 7 deletions
diff --git a/Lib/concurrent/futures/process.py b/Lib/concurrent/futures/process.py index 1f4b242..f0bf6d5 100644 --- a/Lib/concurrent/futures/process.py +++ b/Lib/concurrent/futures/process.py @@ -170,12 +170,12 @@ def _add_call_item_to_queue(pending_work_items, del pending_work_items[work_id] continue -def _queue_manangement_worker(executor_reference, - processes, - pending_work_items, - work_ids_queue, - call_queue, - result_queue): +def _queue_management_worker(executor_reference, + processes, + pending_work_items, + work_ids_queue, + call_queue, + result_queue): """Manages the communication between this process and the worker processes. This function is run in a local thread. @@ -303,7 +303,7 @@ class ProcessPoolExecutor(_base.Executor): q.put(None) if self._queue_management_thread is None: self._queue_management_thread = threading.Thread( - target=_queue_manangement_worker, + target=_queue_management_worker, args=(weakref.ref(self, weakref_cb), self._processes, self._pending_work_items, |