(self, size)
| 965 | |
| 966 | @bigmemtest(size=50, memuse=100*2**20, dry_run=False) |
| 967 | def test_many_threads(self, size): |
| 968 | # Test multiple concurrent put() and get() |
| 969 | q = self.q |
| 970 | inputs = list(range(10000)) |
| 971 | results = self.run_threads(size, q, inputs, self.feed, self.consume) |
| 972 | |
| 973 | # Multiple consumers without synchronization append the |
| 974 | # results in random order |
| 975 | self.assertEqual(sorted(results), inputs) |
| 976 | |
| 977 | @bigmemtest(size=50, memuse=100*2**20, dry_run=False) |
| 978 | def test_many_threads_nonblock(self, size): |
nothing calls this directly
no test coverage detected