(self, num_threads)
| 156 | |
| 157 | class Barrier: |
| 158 | def __init__(self, num_threads): |
| 159 | self.num_threads = num_threads |
| 160 | self.waiting = 0 |
| 161 | self.checkin_mutex = thread.allocate_lock() |
| 162 | self.checkout_mutex = thread.allocate_lock() |
| 163 | self.checkout_mutex.acquire() |
| 164 | |
| 165 | def enter(self): |
| 166 | self.checkin_mutex.acquire() |