diff --git a/kr8s/asyncio/_api.py b/kr8s/asyncio/_api.py
index 5c702c7f..6b0cec33 100644
--- a/kr8s/asyncio/_api.py
+++ b/kr8s/asyncio/_api.py
@@ -1,5 +1,6 @@
 # SPDX-FileCopyrightText: Copyright (c) 2023-2024, Kr8s Developers (See LICENSE for list)
 # SPDX-License-Identifier: BSD 3-Clause License
+import asyncio
 import threading
 
 from kr8s._api import Api as _AsyncApi
@@ -53,18 +54,23 @@ async def api(
     async def _f(**kwargs):
         key = frozenset(kwargs.items())
         thread_id = threading.get_ident()
+        try:
+            loop_id = id(asyncio.get_running_loop())
+        except RuntimeError:
+            loop_id = 0
+        thread_loop_id = (thread_id, loop_id)
         if (
             _cls._instances
-            and thread_id in _cls._instances
-            and key in _cls._instances[thread_id]
+            and thread_loop_id in _cls._instances
+            and key in _cls._instances[thread_loop_id]
         ):
-            return await _cls._instances[thread_id][key]
+            return await _cls._instances[thread_loop_id][key]
         if (
             all(k is None for k in kwargs.values())
-            and thread_id in _cls._instances
-            and list(_cls._instances[thread_id].values())
+            and thread_loop_id in _cls._instances
+            and list(_cls._instances[thread_loop_id].values())
         ):
-            return await list(_cls._instances[thread_id].values())[0]
+            return await list(_cls._instances[thread_loop_id].values())[0]
         return await _cls(**kwargs, bypass_factory=True)
 
     return await _f(
diff --git a/kr8s/tests/test_api.py b/kr8s/tests/test_api.py
index 913cdaaf..e3ecef33 100644
--- a/kr8s/tests/test_api.py
+++ b/kr8s/tests/test_api.py
@@ -65,6 +65,17 @@ async def create_api(q):
     assert type(k1) is type(k2)
 
 
+def test_api_factory_multi_event_loop():
+    assert len(kr8s.Api._instances) == 0
+
+    async def create_api():
+        return await kr8s.asyncio.api()
+
+    k1 = anyio.run(create_api)
+    k2 = anyio.run(create_api)
+    assert k1 is not k2
+
+
 async def test_api_factory_with_kubeconfig(k8s_cluster, serviceaccount):
     k1 = await kr8s.asyncio.api(kubeconfig=k8s_cluster.kubeconfig_path)
     k2 = await kr8s.asyncio.api(serviceaccount=serviceaccount)