feat(wip): threading support(beta)

ididi/graph.py

@@ -862,14 +862,15 @@ def auth_service_factory() -> AuthService: ...
                 old_node = self._nodes[resolved_type]
                 self.remove_node(old_node)
 
-        if inspect.isgeneratorfunction(factory_or_class):
-            func_gen = contextmanager(factory_or_class)
-            node = DependentNode[T].from_node(func_gen, config=node_config)
-        elif inspect.isasyncgenfunction(factory_or_class):
-            func_gen = asynccontextmanager(factory_or_class)
-            node = DependentNode[T].from_node(func_gen, config=node_config)
-        else:
-            node = DependentNode[T].from_node(factory_or_class, config=node_config)
+        with self._lock:
+            if inspect.isgeneratorfunction(factory_or_class):
+                func_gen = contextmanager(factory_or_class)
+                node = DependentNode[T].from_node(func_gen, config=node_config)
+            elif inspect.isasyncgenfunction(factory_or_class):
+                func_gen = asynccontextmanager(factory_or_class)
+                node = DependentNode[T].from_node(func_gen, config=node_config)
+            else:
+                node = DependentNode[T].from_node(factory_or_class, config=node_config)
 
         self.register_node(node)
         return factory_or_class

tests/features/test_nonreuse_trans.py

@@ -0,0 +1,45 @@
+import pytest
+
+from ididi import DependencyGraph
+from ididi.errors import ReusabilityConflictError
+
+
+class Config:
+    def __init__(self, file: str = "file"):
+        self.file = file
+
+
+class Database:
+    def __init__(self, config: Config):
+        self.config = config
+
+
+class Repository:
+    def __init__(self, db: Database):
+        self.db = db
+
+
+class AuthService:
+    def __init__(self, repo: Repository):
+        self.repo = repo
+
+
+def test_reuse_before_nonreuse_error():
+    dg = DependencyGraph()
+    dg.node(reuse=False)(Database)
+    with pytest.raises(ReusabilityConflictError):
+        dg.static_resolve(AuthService)
+
+
+def test_nonreuse_before_nonreuse():
+    dg = DependencyGraph()
+    dg.node(reuse=False)(Database)
+    dg.node(reuse=False)(Repository)
+    dg.node(reuse=False)(AuthService)
+    dg.static_resolve(AuthService)
+
+
+def test_nonreuse_before_reuse():
+    dg = DependencyGraph()
+    dg.node(reuse=False)(AuthService)
+    dg.static_resolve(AuthService)

tests/test_feat.py

@@ -4,48 +4,3 @@
 run test with: make feat
 """
 
-import pytest
-
-from ididi import DependencyGraph
-from ididi.errors import ReusabilityConflictError
-
-
-class Config:
-    def __init__(self, file: str = "file"):
-        self.file = file
-
-
-class Database:
-    def __init__(self, config: Config):
-        self.config = config
-
-
-class Repository:
-    def __init__(self, db: Database):
-        self.db = db
-
-
-class AuthService:
-    def __init__(self, repo: Repository):
-        self.repo = repo
-
-
-def test_reuse_before_nonreuse_error():
-    dg = DependencyGraph()
-    dg.node(reuse=False)(Database)
-    with pytest.raises(ReusabilityConflictError):
-        dg.static_resolve(AuthService)
-
-
-def test_nonreuse_before_nonreuse():
-    dg = DependencyGraph()
-    dg.node(reuse=False)(Database)
-    dg.node(reuse=False)(Repository)
-    dg.node(reuse=False)(AuthService)
-    dg.static_resolve(AuthService)
-
-
-def test_nonreuse_before_reuse():
-    dg = DependencyGraph()
-    dg.node(reuse=False)(AuthService)
-    dg.static_resolve(AuthService)