mirrors/cpython
1
0
Fork 0
mirror of https://github.com/python/cpython.git synced 2025-08-31 14:07:50 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions 9

Merged revisions 65828 via svnmerge from

Browse source 
svn+ssh://pythondev@svn.python.org/python/trunk

........
  r65828 | benjamin.peterson | 2008-08-18 13:31:58 -0500 (Mon, 18 Aug 2008) | 1 line

  patch up multiprocessing until it's API can be changed too
........
This commit is contained in:
Benjamin Peterson 2008-08-18 18:40:08 +00:00
parent 6640d72628
commit fae4c62b1a
4 changed files with 17 additions and 12 deletions
Download patch file Download diff file Expand all files Collapse all files

8
Lib/multiprocessing/pool.py
View file

@ -99,15 +99,15 @@ class Pool(object):
args=(self._inqueue, self._outqueue, initializer, initargs)
)
self._pool.append(w)
w.set_name(w.get_name().replace('Process', 'PoolWorker'))
w.set_daemon(True)
w.name = w.get_name().replace('Process', 'PoolWorker')
w.daemon = True
w.start()
self._task_handler = threading.Thread(
target=Pool._handle_tasks,
args=(self._taskqueue, self._quick_put, self._outqueue, self._pool)
)
self._task_handler.set_daemon(True)
self._task_handler.daemon = True
self._task_handler._state = RUN
self._task_handler.start()
@ -115,7 +115,7 @@ class Pool(object):
target=Pool._handle_results,
args=(self._outqueue, self._quick_get, self._cache)
)
self._result_handler.set_daemon(True)
self._result_handler.daemon = True
self._result_handler._state = RUN
self._result_handler.start()