Lines Matching refs:results
437 def consume(self, q, results, sentinel):
442 results.append(val)
444 def consume_nonblock(self, q, results, sentinel):
455 results.append(val)
457 def consume_timeout(self, q, results, sentinel):
468 results.append(val)
471 results = []
490 args=(q, results, sentinel))
500 return results
549 results = self.run_threads(1, q, inputs, self.feed, self.consume)
551 # One producer, one consumer => results appended in well-defined order
552 self.assertEqual(results, inputs)
559 results = self.run_threads(N, q, inputs, self.feed, self.consume)
562 # results in random order
563 self.assertEqual(sorted(results), inputs)
570 results = self.run_threads(N, q, inputs,
573 self.assertEqual(sorted(results), inputs)
580 results = self.run_threads(N, q, inputs,
583 self.assertEqual(sorted(results), inputs)
628 results = []
644 results.append(q.get())
645 if results[-1] >= N:
648 self.assertEqual(results, list(range(N + 1)))