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