mirror of
https://github.com/python/cpython.git
synced 2024-11-22 05:26:10 +01:00
22 lines
498 B
Python
22 lines
498 B
Python
|
"""Event loop mixins."""
|
||
|
|
|
||
|
|
import threading
|
||
|
|
from . import events
|
||
|
|
|
||
|
|
_global_lock = threading.Lock()
|
||
|
|
|
||
|
|
|
||
|
|
class _LoopBoundedMixin:
|
||
|
|
_loop = None
|
||
|
|
|
||
|
|
def _get_loop(self):
|
||
|
|
loop = events._get_running_loop()
|
||
|
|
|
||
|
|
if self._loop is None:
|
||
|
|
with _global_lock:
|
||
|
|
if self._loop is None:
|
||
|
|
self._loop = loop
|
||
|
|
if loop is not self._loop:
|
||
|
|
raise RuntimeError(f'{type(self).__name__} have already bounded to another loop')
|
||
|
|
return loop
|