mirror of
https://github.com/python/cpython.git
synced 2025-11-03 19:34:08 +00:00
07317b12f3
svn+ssh://pythondev@svn.python.org/python/trunk ........ r66557 | benjamin.peterson | 2008-09-22 16:11:43 -0500 (Mon, 22 Sep 2008) | 1 line use the new threading properties for multiprocessing (reviewed by Jesse #3927) ........
130 lines
3 KiB
Python
130 lines
3 KiB
Python
#
|
|
# Support for the API of the multiprocessing package using threads
|
|
#
|
|
# multiprocessing/dummy/__init__.py
|
|
#
|
|
# Copyright (c) 2006-2008, R Oudkerk --- see COPYING.txt
|
|
#
|
|
|
|
__all__ = [
|
|
'Process', 'current_process', 'active_children', 'freeze_support',
|
|
'Lock', 'RLock', 'Semaphore', 'BoundedSemaphore', 'Condition',
|
|
'Event', 'Queue', 'Manager', 'Pipe', 'Pool', 'JoinableQueue'
|
|
]
|
|
|
|
#
|
|
# Imports
|
|
#
|
|
|
|
import threading
|
|
import sys
|
|
import weakref
|
|
import array
|
|
import itertools
|
|
|
|
from multiprocessing import TimeoutError, cpu_count
|
|
from multiprocessing.dummy.connection import Pipe
|
|
from threading import Lock, RLock, Semaphore, BoundedSemaphore
|
|
from threading import Event
|
|
from queue import Queue
|
|
|
|
#
|
|
#
|
|
#
|
|
|
|
class DummyProcess(threading.Thread):
|
|
|
|
def __init__(self, group=None, target=None, name=None, args=(), kwargs={}):
|
|
threading.Thread.__init__(self, group, target, name, args, kwargs)
|
|
self._pid = None
|
|
self._children = weakref.WeakKeyDictionary()
|
|
self._start_called = False
|
|
self._parent = current_process()
|
|
|
|
def start(self):
|
|
assert self._parent is current_process()
|
|
self._start_called = True
|
|
self._parent._children[self] = None
|
|
threading.Thread.start(self)
|
|
|
|
@property
|
|
def exitcode(self):
|
|
if self._start_called and not self.is_alive():
|
|
return 0
|
|
else:
|
|
return None
|
|
|
|
#
|
|
#
|
|
#
|
|
|
|
class Condition(threading._Condition):
|
|
# XXX
|
|
if sys.version_info < (3, 0):
|
|
notify_all = threading._Condition.notify_all.__func__
|
|
else:
|
|
notify_all = threading._Condition.notify_all
|
|
|
|
#
|
|
#
|
|
#
|
|
|
|
Process = DummyProcess
|
|
current_process = threading.current_thread
|
|
current_process()._children = weakref.WeakKeyDictionary()
|
|
|
|
def active_children():
|
|
children = current_process()._children
|
|
for p in list(children):
|
|
if not p.is_alive():
|
|
children.pop(p, None)
|
|
return list(children)
|
|
|
|
def freeze_support():
|
|
pass
|
|
|
|
#
|
|
#
|
|
#
|
|
|
|
class Namespace(object):
|
|
def __init__(self, **kwds):
|
|
self.__dict__.update(kwds)
|
|
def __repr__(self):
|
|
items = list(self.__dict__.items())
|
|
temp = []
|
|
for name, value in items:
|
|
if not name.startswith('_'):
|
|
temp.append('%s=%r' % (name, value))
|
|
temp.sort()
|
|
return 'Namespace(%s)' % str.join(', ', temp)
|
|
|
|
dict = dict
|
|
list = list
|
|
|
|
def Array(typecode, sequence, lock=True):
|
|
return array.array(typecode, sequence)
|
|
|
|
class Value(object):
|
|
def __init__(self, typecode, value, lock=True):
|
|
self._typecode = typecode
|
|
self._value = value
|
|
def _get(self):
|
|
return self._value
|
|
def _set(self, value):
|
|
self._value = value
|
|
value = property(_get, _set)
|
|
def __repr__(self):
|
|
return '<%r(%r, %r)>'%(type(self).__name__,self._typecode,self._value)
|
|
|
|
def Manager():
|
|
return sys.modules[__name__]
|
|
|
|
def shutdown():
|
|
pass
|
|
|
|
def Pool(processes=None, initializer=None, initargs=()):
|
|
from multiprocessing.pool import ThreadPool
|
|
return ThreadPool(processes, initializer, initargs)
|
|
|
|
JoinableQueue = Queue
|