Lines Matching refs:ctx
37 def __init__(self, maxsize=0, *, ctx):
43 self._rlock = ctx.Lock()
48 self._wlock = ctx.Lock()
49 self._sem = ctx.BoundedSemaphore(maxsize)
296 def __init__(self, maxsize=0, *, ctx):
297 Queue.__init__(self, maxsize, ctx=ctx)
298 self._unfinished_tasks = ctx.Semaphore(0)
299 self._cond = ctx.Condition()
339 def __init__(self, *, ctx):
341 self._rlock = ctx.Lock()
346 self._wlock = ctx.Lock()