mirrors/cpython
1
0
Fork 0
mirror of https://github.com/python/cpython.git synced 2025-08-01 15:43:13 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions 8

get rid of 2.6/3.0 switch statements in multiprocessing

Browse source
This commit is contained in:
Benjamin Peterson 2008-06-25 12:44:29 +00:00
parent b09c9396cd
commit 264800822a
2 changed files with 6 additions and 23 deletions
Download patch file Download diff file Expand all files Collapse all files

24
Lib/multiprocessing/dummy/__init__.py
View file

@ -53,30 +53,18 @@ class DummyProcess(threading.Thread):
else: else:
return None return None
# XXX is_alive = threading.Thread.is_alive.im_func
if sys.version_info < (3, 0): get_name = threading.Thread.get_name.im_func
is_alive = threading.Thread.is_alive.im_func set_name = threading.Thread.set_name.im_func
get_name = threading.Thread.get_name.im_func is_daemon = threading.Thread.is_daemon.im_func
set_name = threading.Thread.set_name.im_func set_daemon = threading.Thread.set_daemon.im_func
is_daemon = threading.Thread.is_daemon.im_func
set_daemon = threading.Thread.set_daemon.im_func
else:
is_alive = threading.Thread.is_alive
get_name = threading.Thread.get_name
set_name = threading.Thread.set_name
is_daemon = threading.Thread.is_daemon
set_daemon = threading.Thread.set_daemon
# #
# #
# #
class Condition(threading._Condition): class Condition(threading._Condition):
# XXX notify_all = threading._Condition.notify_all.im_func
if sys.version_info < (3, 0):
notify_all = threading._Condition.notify_all.im_func
else:
notify_all = threading._Condition.notify_all
# #
# #

5
Lib/multiprocessing/managers.py
View file

@ -41,11 +41,6 @@ def reduce_array(a):
copy_reg.pickle(array.array, reduce_array) copy_reg.pickle(array.array, reduce_array)
view_types = [type(getattr({}, name)()) for name in ('items','keys','values')] view_types = [type(getattr({}, name)()) for name in ('items','keys','values')]
if view_types[0] is not list: # XXX only needed in Py3.0
def rebuild_as_list(obj):
return list, (list(obj),)
for view_type in view_types:
copy_reg.pickle(view_type, rebuild_as_list)
# #
# Type for identifying shared objects # Type for identifying shared objects