From 5d97b7bcc19496617bf8c448d2f149cc28c73bc7 Mon Sep 17 00:00:00 2001 From: Yury Selivanov Date: Tue, 29 May 2018 15:38:07 -0400 Subject: bpo-22087: Fix Policy.get_event_loop() to detect fork (GH-7208) Original patch by Dan O'Reilly. --- Lib/asyncio/events.py | 7 +++++++ 1 file changed, 7 insertions(+) (limited to 'Lib/asyncio') diff --git a/Lib/asyncio/events.py b/Lib/asyncio/events.py index 40946bbf65..68dc25e1e8 100644 --- a/Lib/asyncio/events.py +++ b/Lib/asyncio/events.py @@ -625,16 +625,23 @@ class BaseDefaultEventLoopPolicy(AbstractEventLoopPolicy): class _Local(threading.local): _loop = None + _pid = None _set_called = False def __init__(self): self._local = self._Local() + self._local._pid = os.getpid() def get_event_loop(self): """Get the event loop. This may be None or an instance of EventLoop. """ + if self._local._pid != os.getpid(): + # If we detect we're in a child process forked by multiprocessing, + # we reset self._local so that we'll get a new event loop. + self._local = self._Local() + if (self._local._loop is None and not self._local._set_called and isinstance(threading.current_thread(), threading._MainThread)): -- cgit v1.2.1