add concurrently (extra)

Signed-off-by: Mattias Andrée <maandree@operamail.com>

1 files changed, 9 insertions, 0 deletions

diff --git a/src/test.py b/src/test.py
index ae76886..987fe0c 100755
--- a/src/test.py
+++ b/src/test.py
@@ -94,6 +94,15 @@ def unordered_join(*f_groups):
     return rc
 
 
+# extra, not a part of join-calculus
+def concurrently(*fs):
+    ts = [threading.Thread(target = f, args = args, kwargs = kwargs) for f in fs]
+    for t in ts:
+        ts.start()
+    for t in ts:
+        ts.join()
+
+
 class test:
     @signal
     def signal(f, *args):