Acquire the group lock for a specific group `group_id`.
(self, group_id)
| 84 | return self._Context(self, group_id) |
| 85 | |
| 86 | def acquire(self, group_id): |
| 87 | """Acquire the group lock for a specific group `group_id`.""" |
| 88 | self._validate_group_id(group_id) |
| 89 | |
| 90 | self._ready.acquire() |
| 91 | while self._another_group_active(group_id): |
| 92 | self._ready.wait() |
| 93 | self._group_member_counts[group_id] += 1 |
| 94 | self._ready.release() |
| 95 | |
| 96 | def release(self, group_id): |
| 97 | """Release the group lock for a specific group `group_id`.""" |