patch up multiprocessing until it's API can be changed too

This commit is contained in:
Benjamin Peterson 2008-08-18 18:31:58 +00:00
parent d810626f99
commit 82aa201022
4 changed files with 17 additions and 11 deletions

View File

@ -54,10 +54,10 @@ class DummyProcess(threading.Thread):
return None
is_alive = threading.Thread.is_alive.im_func
get_name = threading.Thread.get_name.im_func
set_name = threading.Thread.set_name.im_func
is_daemon = threading.Thread.is_daemon.im_func
set_daemon = threading.Thread.set_daemon.im_func
get_name = threading.Thread.getName.im_func
set_name = threading.Thread.setName.im_func
is_daemon = threading.Thread.isDaemon.im_func
set_daemon = threading.Thread.setDaemon.im_func
#
#

View File

@ -154,7 +154,7 @@ class Server(object):
except (OSError, IOError):
continue
t = threading.Thread(target=self.handle_request, args=(c,))
t.set_daemon(True)
t.daemon = True
t.start()
except (KeyboardInterrupt, SystemExit):
pass

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()

View File

@ -619,11 +619,17 @@ class _TestCondition(BaseTestCase):
woken = self.Semaphore(0)
p = self.Process(target=self.f, args=(cond, sleeping, woken))
p.set_daemon(True)
try:
p.set_daemon(True)
except AttributeError:
p.daemon = True
p.start()
p = threading.Thread(target=self.f, args=(cond, sleeping, woken))
p.set_daemon(True)
try:
p.set_daemon(True)
except AttributeError:
p.daemon = True
p.start()
# wait for both children to start sleeping