(self, size)
| 978 | |
| 979 | @bigmemtest(size=50, memuse=100*2**20, dry_run=False) |
| 980 | def test_many_threads_nonblock(self, size): |
| 981 | # Test multiple concurrent put() and get(block=False) |
| 982 | q = self.q |
| 983 | inputs = list(range(10000)) |
| 984 | results = self.run_threads(size, q, inputs, |
| 985 | self.feed, self.consume_nonblock) |
| 986 | |
| 987 | self.assertEqual(sorted(results), inputs) |
| 988 | |
| 989 | @bigmemtest(size=50, memuse=100*2**20, dry_run=False) |
| 990 | def test_many_threads_timeout(self, size): |
nothing calls this directly
no test coverage detected