(self)
| 957 | q.get(timeout=-1) |
| 958 | |
| 959 | def test_order(self): |
| 960 | # Test a pair of concurrent put() and get() |
| 961 | q = self.q |
| 962 | inputs = list(range(100)) |
| 963 | results = self.run_threads(1, q, inputs, self.feed, self.consume) |
| 964 | |
| 965 | # One producer, one consumer => results appended in well-defined order |
| 966 | self.assertEqual(results, inputs) |
| 967 | |
| 968 | @bigmemtest(size=50, memuse=100*2**20, dry_run=False) |
| 969 | def test_many_threads(self, size): |
nothing calls this directly
no test coverage detected