Lines Matching refs:sentinel
426 def feed(self, q, seq, rnd, sentinel):
431 q.put(sentinel)
437 def consume(self, q, results, sentinel):
440 if val == sentinel:
444 def consume_nonblock(self, q, results, sentinel):
453 if val == sentinel:
457 def consume_timeout(self, q, results, sentinel):
466 if val == sentinel:
472 sentinel = None
487 args=(q, seq, rnd, sentinel))
490 args=(q, results, sentinel))