this should be called multiprocessing

Author: crazyeng

wolframclient/serializers/encoder.py

@@ -6,7 +6,7 @@
 from functools import partial
 
 from wolframclient.serializers.utils import safe_len
-from wolframclient.utils.api import multithreading, pkg_resources
+from wolframclient.utils.api import multiprocessing, pkg_resources
 from wolframclient.utils.dispatch import Dispatch
 from wolframclient.utils.functional import composition, is_iterable, iterate, map
 from wolframclient.utils.importutils import safe_import_string
@@ -64,7 +64,7 @@ def _update_plugins(self):
     # global lock to avoid multiple dispatcher updating in multithreaded programs.
 
     def update_dispatch(self):
-        with multithreading.Lock():
+        with multiprocessing.Lock():
             self._update_dispatch()
             self._update_plugins()
 

wolframclient/utils/api.py

@@ -147,7 +147,7 @@
     PackedArray="wolframclient.utils.packedarray.PackedArray",
 )
 
-multithreading = API(Lock="wolframclient.utils.lock.Lock")
+multiprocessing = API(Lock="wolframclient.utils.lock.Lock")
 pkg_resources = API(
     iter_entry_points=("pkg_resources.iter_entry_points", lambda *args, **opts: ())
 )

wolframclient/utils/lock.py

@@ -3,7 +3,7 @@
 from wolframclient.utils.importutils import safe_import_string_and_call
 
 try:
-    _lock = safe_import_string_and_call("multithreading.Lock")
+    _lock = safe_import_string_and_call("multiprocessing.Lock")
 
     def Lock():
         return _lock