(self, size)
| 988 | |
| 989 | @bigmemtest(size=50, memuse=100*2**20, dry_run=False) |
| 990 | def test_many_threads_timeout(self, size): |
| 991 | # Test multiple concurrent put() and get(timeout=...) |
| 992 | q = self.q |
| 993 | inputs = list(range(1000)) |
| 994 | results = self.run_threads(size, q, inputs, |
| 995 | self.feed, self.consume_timeout) |
| 996 | |
| 997 | self.assertEqual(sorted(results), inputs) |
| 998 | |
| 999 | def test_references(self): |
| 1000 | # The queue should lose references to each item as soon as |
nothing calls this directly
no test coverage detected