home *** CD-ROM | disk | FTP | other *** search
/ Mac Easy 2010 May / Mac Life Ubuntu.iso / casper / filesystem.squashfs / usr / lib / python2.6 / multiprocessing / dummy / __init__.py next >
Encoding:
Python Source  |  2009-04-18  |  2.9 KB  |  127 lines
  1. #
  2. # Support for the API of the multiprocessing package using threads
  3. #
  4. # multiprocessing/dummy/__init__.py
  5. #
  6. # Copyright (c) 2006-2008, R Oudkerk --- see COPYING.txt
  7. #
  8.  
  9. __all__ = [
  10.     'Process', 'current_process', 'active_children', 'freeze_support',
  11.     'Lock', 'RLock', 'Semaphore', 'BoundedSemaphore', 'Condition',
  12.     'Event', 'Queue', 'Manager', 'Pipe', 'Pool', 'JoinableQueue'
  13.     ]
  14.  
  15. #
  16. # Imports
  17. #
  18.  
  19. import threading
  20. import sys
  21. import weakref
  22. import array
  23. import itertools
  24.  
  25. from multiprocessing import TimeoutError, cpu_count
  26. from multiprocessing.dummy.connection import Pipe
  27. from threading import Lock, RLock, Semaphore, BoundedSemaphore
  28. from threading import Event
  29. from Queue import Queue
  30.  
  31. #
  32. #
  33. #
  34.  
  35. class DummyProcess(threading.Thread):
  36.  
  37.     def __init__(self, group=None, target=None, name=None, args=(), kwargs={}):
  38.         threading.Thread.__init__(self, group, target, name, args, kwargs)
  39.         self._pid = None
  40.         self._children = weakref.WeakKeyDictionary()
  41.         self._start_called = False
  42.         self._parent = current_process()
  43.  
  44.     def start(self):
  45.         assert self._parent is current_process()
  46.         self._start_called = True
  47.         self._parent._children[self] = None
  48.         threading.Thread.start(self)
  49.  
  50.     @property
  51.     def exitcode(self):
  52.         if self._start_called and not self.is_alive():
  53.             return 0
  54.         else:
  55.             return None
  56.  
  57. #
  58. #
  59. #
  60.  
  61. class Condition(threading._Condition):
  62.     notify_all = threading._Condition.notify_all.im_func
  63.  
  64. #
  65. #
  66. #
  67.  
  68. Process = DummyProcess
  69. current_process = threading.current_thread
  70. current_process()._children = weakref.WeakKeyDictionary()
  71.  
  72. def active_children():
  73.     children = current_process()._children
  74.     for p in list(children):
  75.         if not p.is_alive():
  76.             children.pop(p, None)
  77.     return list(children)
  78.  
  79. def freeze_support():
  80.     pass
  81.  
  82. #
  83. #
  84. #
  85.  
  86. class Namespace(object):
  87.     def __init__(self, **kwds):
  88.         self.__dict__.update(kwds)
  89.     def __repr__(self):
  90.         items = self.__dict__.items()
  91.         temp = []
  92.         for name, value in items:
  93.             if not name.startswith('_'):
  94.                 temp.append('%s=%r' % (name, value))
  95.         temp.sort()
  96.         return 'Namespace(%s)' % str.join(', ', temp)
  97.  
  98. dict = dict
  99. list = list
  100.  
  101. def Array(typecode, sequence, lock=True):
  102.     return array.array(typecode, sequence)
  103.  
  104. class Value(object):
  105.     def __init__(self, typecode, value, lock=True):
  106.         self._typecode = typecode
  107.         self._value = value
  108.     def _get(self):
  109.         return self._value
  110.     def _set(self, value):
  111.         self._value = value
  112.     value = property(_get, _set)
  113.     def __repr__(self):
  114.         return '<%r(%r, %r)>'%(type(self).__name__,self._typecode,self._value)
  115.  
  116. def Manager():
  117.     return sys.modules[__name__]
  118.  
  119. def shutdown():
  120.     pass
  121.  
  122. def Pool(processes=None, initializer=None, initargs=()):
  123.     from multiprocessing.pool import ThreadPool
  124.     return ThreadPool(processes, initializer, initargs)
  125.  
  126. JoinableQueue = Queue
  127.