Mark the running thread as waiting for self.lock. via _blocking_on.
(self)
| 160 | self.lock = lock |
| 161 | |
| 162 | def __enter__(self): |
| 163 | """Mark the running thread as waiting for self.lock. via _blocking_on.""" |
| 164 | # Interactions with _blocking_on are *not* protected by the global |
| 165 | # import lock here because each thread only touches the state that it |
| 166 | # owns (state keyed on its thread id). The global import lock is |
| 167 | # re-entrant (i.e., a single thread may take it more than once) so it |
| 168 | # wouldn't help us be correct in the face of re-entrancy either. |
| 169 | |
| 170 | self.blocked_on = _blocking_on.setdefault(self.thread_id, _List()) |
| 171 | self.blocked_on.append(self.lock) |
| 172 | |
| 173 | def __exit__(self, *args, **kwargs): |
| 174 | """Remove self.lock from this thread's _blocking_on list.""" |
nothing calls this directly
no test coverage detected