mirrors/cpython
1
0
Fork 0
mirror of https://github.com/python/cpython.git synced 2025-10-17 20:28:43 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions 9

Fix typo in name of private function

Browse source
This commit is contained in:
Antoine Pitrou 2011-05-03 16:34:42 +02:00
parent a5ac2ce982
commit b87a56a519
1 changed files with 7 additions and 7 deletions
Download patch file Download diff file Expand all files Collapse all files

14
Lib/concurrent/futures/process.py
View file

@ -169,12 +169,12 @@ def _add_call_item_to_queue(pending_work_items,
del pending_work_items[work_id] del pending_work_items[work_id]
continue continue
def _queue_manangement_worker(executor_reference, def _queue_management_worker(executor_reference,
processes, processes,
pending_work_items, pending_work_items,
work_ids_queue, work_ids_queue,
call_queue, call_queue,
result_queue): result_queue):
"""Manages the communication between this process and the worker processes. """Manages the communication between this process and the worker processes.
This function is run in a local thread. This function is run in a local thread.
@ -302,7 +302,7 @@ class ProcessPoolExecutor(_base.Executor):
q.put(None) q.put(None)
if self._queue_management_thread is None: if self._queue_management_thread is None:
self._queue_management_thread = threading.Thread( self._queue_management_thread = threading.Thread(
target=_queue_manangement_worker, target=_queue_management_worker,
args=(weakref.ref(self, weakref_cb), args=(weakref.ref(self, weakref_cb),
self._processes, self._processes,
self._pending_work_items, self._pending_work_items,