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