Lines Matching refs:self
41 def cpu_count(self):
49 def Manager(self):
56 m = SyncManager(ctx=self.get_context())
60 def Pipe(self, duplex=True):
65 def Lock(self):
68 return Lock(ctx=self.get_context())
70 def RLock(self):
73 return RLock(ctx=self.get_context())
75 def Condition(self, lock=None):
78 return Condition(lock, ctx=self.get_context())
80 def Semaphore(self, value=1):
83 return Semaphore(value, ctx=self.get_context())
85 def BoundedSemaphore(self, value=1):
88 return BoundedSemaphore(value, ctx=self.get_context())
90 def Event(self):
93 return Event(ctx=self.get_context())
95 def Barrier(self, parties, action=None, timeout=None):
98 return Barrier(parties, action, timeout, ctx=self.get_context())
100 def Queue(self, maxsize=0):
103 return Queue(maxsize, ctx=self.get_context())
105 def JoinableQueue(self, maxsize=0):
108 return JoinableQueue(maxsize, ctx=self.get_context())
110 def SimpleQueue(self):
113 return SimpleQueue(ctx=self.get_context())
115 def Pool(self, processes=None, initializer=None, initargs=(),
120 context=self.get_context())
122 def RawValue(self, typecode_or_type, *args):
127 def RawArray(self, typecode_or_type, size_or_initializer):
132 def Value(self, typecode_or_type, *args, lock=True):
136 ctx=self.get_context())
138 def Array(self, typecode_or_type, size_or_initializer, *, lock=True):
142 ctx=self.get_context())
144 def freeze_support(self):
152 def get_logger(self):
159 def log_to_stderr(self, level=None):
164 def allow_connection_pickling(self):
172 def set_executable(self, executable):
180 def set_forkserver_preload(self, module_names):
187 def get_context(self, method=None):
189 return self
197 def get_start_method(self, allow_none=False):
198 return self._name
200 def set_start_method(self, method, force=False):
204 def reducer(self):
210 def reducer(self, reduction):
213 def _check_available(self):
233 def __init__(self, context):
234 self._default_context = context
235 self._actual_context = None
237 def get_context(self, method=None):
239 if self._actual_context is None:
240 self._actual_context = self._default_context
241 return self._actual_context
245 def set_start_method(self, method, force=False):
246 if self._actual_context is not None and not force:
249 self._actual_context = None
251 self._actual_context = self.get_context(method)
253 def get_start_method(self, allow_none=False):
254 if self._actual_context is None:
257 self._actual_context = self._default_context
258 return self._actual_context._name
260 def get_all_start_methods(self):
313 def _check_available(self):