(self, q, seq, rnd, sentinel)
| 838 | self.q = self.type2test() |
| 839 | |
| 840 | def feed(self, q, seq, rnd, sentinel): |
| 841 | while True: |
| 842 | try: |
| 843 | val = seq.pop() |
| 844 | except IndexError: |
| 845 | q.put(sentinel) |
| 846 | return |
| 847 | q.put(val) |
| 848 | if rnd.random() > 0.5: |
| 849 | time.sleep(rnd.random() * 1e-3) |
| 850 | |
| 851 | def consume(self, q, results, sentinel): |
| 852 | while True: |
no test coverage detected