(self, ident)
| 48 | self.running += 1 |
| 49 | |
| 50 | def task(self, ident): |
| 51 | with self.random_mutex: |
| 52 | delay = random.random() / 10000.0 |
| 53 | verbose_print("task %s will run for %sus" % (ident, round(delay*1e6))) |
| 54 | time.sleep(delay) |
| 55 | verbose_print("task %s done" % ident) |
| 56 | with self.running_mutex: |
| 57 | self.running -= 1 |
| 58 | if self.created == NUMTASKS and self.running == 0: |
| 59 | self.done_mutex.release() |
| 60 | |
| 61 | def test_starting_threads(self): |
| 62 | with threading_helper.wait_threads_exit(): |