Lines Matching refs:ctx
163 def __init__(self, max_size=0, *, ctx, pending_work_items, shutdown_lock,
168 super().__init__(max_size, ctx=ctx)
226 call_queue: A ctx.Queue of _CallItems that will be read and
228 result_queue: A ctx.Queue of _ResultItems that will written
310 # A list of the ctx.Process instances used as workers.
313 # A ctx.Queue that will be filled with _CallItems derived from
317 # A ctx.SimpleQueue of _ResultItems generated by the process workers.
551 # some ctx.Queue methods may deadlock on Mac OS X.
712 max_size=queue_size, ctx=self._mp_context,