__slots__ for concurrency blocks

chainlet/concurrency/base.py

@@ -212,7 +212,7 @@ class LocalExecutor(object):
     :param identifier: base identifier for all workers
     :type identifier: str
     """
-    _min_workers = max(CPU_CONCURRENCY, 2)
+    __slots__ = ('identifier', '_max_workers')
 
     def __init__(self, max_workers, identifier=''):
         self.identifier = identifier or ('%s_%d' % (self.__class__.__name__, id(self)))
@@ -244,6 +244,7 @@ class ConcurrentBundle(bundle.Bundle):
     Concurrent bundles implement element concurrency:
     the same data is processed concurrently by multiple elements.
     """
+    __slots__ = ()
     executor = DEFAULT_EXECUTOR
 
     def chainlet_send(self, value=None):
@@ -275,6 +276,7 @@ class ConcurrentChain(chain.Chain):
     :note: A :py:class:`ConcurrentChain` will *always* :term:`join`
            and :term:`fork` to handle all data.
     """
+    __slots__ = ('_stripes',)
     executor = DEFAULT_EXECUTOR
 
     def __init__(self, elements):

chainlet/concurrency/thread.py

@@ -34,10 +34,11 @@ class ThreadPoolExecutor(LocalExecutor):
     :param identifier: base identifier for all workers
     :type identifier: str
     """
-    _min_workers = max(CPU_CONCURRENCY, 2)
+    __slots__ = ('_workers', '_queue', '_min_workers')
 
     def __init__(self, max_workers, identifier=''):
         super(ThreadPoolExecutor, self).__init__(max_workers=max_workers, identifier=identifier)
+        self._min_workers = max(CPU_CONCURRENCY, 2)
         self._workers = set()
         self._queue = queue.Queue()
         self._ensure_worker()
@@ -115,6 +116,7 @@ class ThreadLinkPrimitives(linker.LinkPrimitives):
 class ThreadBundle(ConcurrentBundle):
     chain_types = ThreadLinkPrimitives()
     executor = DEFAULT_EXECUTOR
+    __slots__ = ()
 
     def __repr__(self):
         return 'threads(%s)' % super(ThreadBundle, self).__repr__()
@@ -123,6 +125,7 @@ def __repr__(self):
 class ThreadChain(ConcurrentChain):
     chain_types = ThreadLinkPrimitives()
     executor = DEFAULT_EXECUTOR
+    __slots__ = ()
 
     def __repr__(self):
         return 'threads(%s)' % super(ThreadChain, self).__repr__()