fix: Future attached to different loop

a_sync/executor.py

@@ -23,6 +23,7 @@
 from asyncio import sleep
 from asyncio.futures import _convert_future_exc
 from concurrent.futures import _base, thread
+from functools import cached_property
 
 from a_sync._typing import *
 from a_sync.primitives._debug import _DebugDaemonMixin
@@ -206,6 +207,16 @@ def worker_count_current(self) -> int:
         """
         return len(getattr(self, f"_{self._workers}"))
 
+    @cached_property
+    def _create_future(self) -> Callable[[], asyncio.Future]:
+        # This helper lets us defer getting the loop during init so the user can set a different one
+        return self._get_loop().create_future
+
+    @cached_property
+    def _call_soon_threadsafe(self) -> Callable[..., asyncio.TimerHandle]:
+        # This helper lets us defer getting the loop during init so the user can set a different one
+        return self._get_loop().call_soon_threadsafe
+
     def __init_mixin__(self):
         self.sync_mode = self._max_workers == 0
         self.__super_submit = super().submit