add more multiprocessing examples

examples/python/multiprocessing/callback.kg

@@ -0,0 +1,7 @@
+.py("callback.py")
+
+cb::{.p(x);x*x}
+
+.p("running callback in parallel processes: ")
+.p(runit(!10;cb))
+

examples/python/multiprocessing/callback.py

@@ -0,0 +1,21 @@
+import multiprocessing
+from klongpy import KlongInterpreter
+from klongpy.core import KGFnWrapper
+
+def use_klongpy(args):
+    """
+    This runs in a separate process so we need to instantiate a Klong interpreter.
+    The incoming function was serialized from the main process and marshaled to the parallel process.
+    We can run it in the new Klong context.
+    """
+    n, fn = args
+    klong = KlongInterpreter()
+    fn = KGFnWrapper(klong, fn)
+    return fn(n)
+
+
+def runit(numbers, fn):
+    """Apply the square function in parallel to a list of numbers."""
+    with multiprocessing.Pool(1) as pool:
+        results = pool.map(use_klongpy, [(n,fn) for n in numbers])
+    return results

examples/python/multiprocessing/pool.kg

@@ -1,3 +1,3 @@
 .py("pool.py")
 
-runit(!10)
+.d("parallel squared numbers: ");.p(runit(!10))

examples/python/multiprocessing/worker/par.kg

@@ -0,0 +1,5 @@
+.py("par.py")
+
+.p("running workers in parallel processes: ")
+.p(runit(!10;"worker.kg";"worker"))
+

examples/python/multiprocessing/worker/par.py

@@ -0,0 +1,19 @@
+import multiprocessing
+from klongpy import KlongInterpreter
+from klongpy.core import KGFnWrapper
+
+def use_klongpy(args):
+    """
+    """
+    n, fname, fn_name = args
+    klong = KlongInterpreter()
+    klong(f'.l("{fname}")')
+    return klong[fn_name](n)
+
+
+def runit(numbers, fname, fn_name):
+    """
+    """
+    with multiprocessing.Pool(1) as pool:
+        results = pool.map(use_klongpy, [(n,fname,fn_name) for n in numbers])
+    return results

examples/python/multiprocessing/worker/worker.kg

@@ -0,0 +1,2 @@
+worker::{.p(x);x*x}
+