extracted event loop in a separate class

ably/decorator/sync.py

@@ -1,23 +1,7 @@
-import asyncio
 import functools
-import threading
 from asyncio import events
 
-_loop: events = None
-_thread: threading = None
-
-
-def get_custom_event_loop() -> events:
-    global _loop, _thread
-    if _thread is None:
-        if _loop is None:
-            _loop = asyncio.new_event_loop()
-        if not _loop.is_running():
-            _thread = threading.Thread(
-                target=_loop.run_forever,
-                daemon=True)
-            _thread.start()
-    return _loop
+from ably.executer.eventloop import AblyEventLoop
 
 
 def optional_sync(fn):
@@ -35,7 +19,7 @@ def wrapper(*args, **kwargs):
             caller_eventloop: events = asyncio.get_running_loop()
         except:
             pass
-        ably_eventloop: events = get_custom_event_loop()
+        ably_eventloop: events = AblyEventLoop.get_global().loop
 
         # Handle calls from ably_eventloop on the same loop, return awaitable
         if caller_eventloop is not None and caller_eventloop == ably_eventloop:

ably/executer/eventloop.py

@@ -0,0 +1,34 @@
+import asyncio
+import threading
+from asyncio import events
+from threading import Thread
+
+
+class AblyEventLoop:
+    loop: events
+    thread: Thread
+
+    __global_event_loop: 'AblyEventLoop' = None
+
+    @staticmethod
+    def get_global() -> 'AblyEventLoop':
+        if AblyEventLoop.__global_event_loop is None:
+            AblyEventLoop.__global_event_loop = AblyEventLoop()
+            AblyEventLoop.__global_event_loop._create_if_not_exist()
+        return AblyEventLoop.__global_event_loop
+
+    def _create_if_not_exist(self):
+        if self.loop is None:
+            self.loop = asyncio.new_event_loop()
+        if not self.loop.is_running():
+            self.thread = threading.Thread(
+                target=self.loop.run_forever,
+                daemon=True)
+            self.thread.start()
+
+    def close(self) -> events:
+        self.loop.stop()
+        self.loop.close()
+        self.loop = None
+        self.thread = None
+