Commit a87501fd authored by Victor Stinner's avatar Victor Stinner

asyncio: BaseEventLoop: rename _owner to _thread_id

parent 05784a70
...@@ -188,7 +188,7 @@ class BaseEventLoop(events.AbstractEventLoop): ...@@ -188,7 +188,7 @@ class BaseEventLoop(events.AbstractEventLoop):
self._internal_fds = 0 self._internal_fds = 0
# Identifier of the thread running the event loop, or None if the # Identifier of the thread running the event loop, or None if the
# event loop is not running # event loop is not running
self._owner = None self._thread_id = None
self._clock_resolution = time.get_clock_info('monotonic').resolution self._clock_resolution = time.get_clock_info('monotonic').resolution
self._exception_handler = None self._exception_handler = None
self._debug = (not sys.flags.ignore_environment self._debug = (not sys.flags.ignore_environment
...@@ -269,7 +269,7 @@ class BaseEventLoop(events.AbstractEventLoop): ...@@ -269,7 +269,7 @@ class BaseEventLoop(events.AbstractEventLoop):
self._check_closed() self._check_closed()
if self.is_running(): if self.is_running():
raise RuntimeError('Event loop is running.') raise RuntimeError('Event loop is running.')
self._owner = threading.get_ident() self._thread_id = threading.get_ident()
try: try:
while True: while True:
try: try:
...@@ -277,7 +277,7 @@ class BaseEventLoop(events.AbstractEventLoop): ...@@ -277,7 +277,7 @@ class BaseEventLoop(events.AbstractEventLoop):
except _StopError: except _StopError:
break break
finally: finally:
self._owner = None self._thread_id = None
def run_until_complete(self, future): def run_until_complete(self, future):
"""Run until the Future is done. """Run until the Future is done.
...@@ -362,7 +362,7 @@ class BaseEventLoop(events.AbstractEventLoop): ...@@ -362,7 +362,7 @@ class BaseEventLoop(events.AbstractEventLoop):
def is_running(self): def is_running(self):
"""Returns True if the event loop is running.""" """Returns True if the event loop is running."""
return (self._owner is not None) return (self._thread_id is not None)
def time(self): def time(self):
"""Return the time according to the event loop's clock. """Return the time according to the event loop's clock.
...@@ -449,10 +449,10 @@ class BaseEventLoop(events.AbstractEventLoop): ...@@ -449,10 +449,10 @@ class BaseEventLoop(events.AbstractEventLoop):
Should only be called when (self._debug == True). The caller is Should only be called when (self._debug == True). The caller is
responsible for checking this condition for performance reasons. responsible for checking this condition for performance reasons.
""" """
if self._owner is None: if self._thread_id is None:
return return
thread_id = threading.get_ident() thread_id = threading.get_ident()
if thread_id != self._owner: if thread_id != self._thread_id:
raise RuntimeError( raise RuntimeError(
"Non-thread-safe operation invoked on an event loop other " "Non-thread-safe operation invoked on an event loop other "
"than the current one") "than the current one")
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment