Lines Matching refs:results
1843 def multipass(cls, barrier, results, n):
1847 results[0].append(True)
1848 assert len(results[1]) == i * m
1850 results[1].append(True)
1851 assert len(results[0]) == (i + 1) * m
1863 results = [self.DummyList(), self.DummyList()]
1864 self.run_threads(self.multipass, (self.barrier, results, passes))
1883 results = [queue.get() for i in range(self.N)]
1884 self.assertEqual(results.count(0), 1)
1888 def _test_action_f(cls, barrier, results):
1890 if len(results) != 1:
1897 results = self.DummyList()
1898 barrier = self.Barrier(self.N, action=AppendTrue(results))
1899 self.run_threads(self._test_action_f, (barrier, results))
1900 self.assertEqual(len(results), 1)
1996 def _test_timeout_f(cls, barrier, results):
2004 results.append(True)
2010 results = self.DummyList()
2011 self.run_threads(self._test_timeout_f, (self.barrier, results))
2012 self.assertEqual(len(results), self.barrier.parties)
2015 def _test_default_timeout_f(cls, barrier, results):
2023 results.append(True)
2030 results = self.DummyList()
2031 self.run_threads(self._test_default_timeout_f, (barrier, results))
2032 self.assertEqual(len(results), barrier.parties)
2553 # SayWhenError seen at start of problematic chunk's results
2727 # Issue #29861: task arguments and results should not be kept
2827 results = []
2829 results.append(p.apply_async(sqr, (i, )))
2830 # Fetch the results and verify we got the right answers,
2832 for (j, res) in enumerate(results):
2855 results = []
2857 results.append(p.apply_async(sqr, (i, 0.3)))
2860 # check the results
2861 for (j, res) in enumerate(results):