Lines Matching refs:self

81     def _repopulate_pool(self):  argument
87 for i in range(self._processes - len(self._pool)):
88 w = self.Process(target=tbb_process_pool_worker27,
89 args=(self._inqueue, self._outqueue,
90 self._initializer,
91 self._initargs, self._maxtasksperchild)
93 self._pool.append(w)
99 def __del__(self): argument
100 self.close()
101 for p in self._pool:
104 def __exit__(self, *args): argument
105 self.close()
106 for p in self._pool:
123 def _repopulate_pool(self): argument
129 for i in range(self._processes - len(self._pool)):
130 w = self.Process(target=tbb_process_pool_worker3,
131 args=(self._inqueue, self._outqueue,
132 self._initializer,
133 self._initargs, self._maxtasksperchild,
134 self._wrap_exception)
136 self._pool.append(w)
142 def __del__(self): argument
143 self.close()
144 for p in self._pool:
147 def __exit__(self, *args): argument
148 self.close()
149 for p in self._pool:
169 def __init__(self, max_num_threads=None, benchmark=False): argument
176 self.ctl = global_control(global_control.max_allowed_parallelism, int(max_num_threads))
183 def _patch(self, class_name, module_name, obj): argument
184 m = self._modules[class_name] = __import__(module_name, globals(),
190 self._modules[class_name] = None
192 self._items[class_name] = oldattr
195 def __enter__(self): argument
199 self.env_mkl = os.getenv('MKL_THREADING_LAYER')
201 self.env_numba = os.getenv('NUMBA_THREADING_LAYER')
206 self._patch("Pool", "multiprocessing.pool", TBBProcessPool27)
208 self._patch("Pool", "multiprocessing.pool", TBBProcessPool3)
209 self._patch("ThreadPool", "multiprocessing.pool", Pool)
210 return self
212 def __exit__(self, exc_type, exc_value, traceback): argument
216 if self.env_mkl is None:
219 os.environ['MKL_THREADING_LAYER'] = self.env_mkl
220 if self.env_numba is None:
223 os.environ['NUMBA_THREADING_LAYER'] = self.env_numba
224 for name in self._items.keys():
225 setattr(self._modules[name], name, self._items[name])