Added a new function pmap to Async module

refs #7703

Change-Id: I848203393d115a0c8f9bbbfbf80e47f35f17616d

diff --git a/bundles/org.simantics.scl.runtime/scl/Async.scl b/bundles/org.simantics.scl.runtime/scl/Async.scl
index c47f457ef7d5751aa5e5d0c8bc2056b0219368d5..9ff397f19cdf2fec1a89dc2c933598d2c5678133 100644 (file)
--- a/bundles/org.simantics.scl.runtime/scl/Async.scl
+++ b/bundles/org.simantics.scl.runtime/scl/Async.scl
@@ -1,2 +1,3 @@
 importJava "org.simantics.scl.runtime.utils.AsyncUtils" where
-    runAsync :: (<Proc> a) -> <Proc> ()
\ No newline at end of file
+    runAsync :: (<Proc> a) -> <Proc> ()
+    pmap :: (a -> b) -> [a] -> [b]

diff --git a/bundles/org.simantics.scl.runtime/src/org/simantics/scl/runtime/utils/AsyncUtils.java b/bundles/org.simantics.scl.runtime/src/org/simantics/scl/runtime/utils/AsyncUtils.java
index 29886f21ee960e916f6078d581f4d2032f142414..3392d461c2ed05ae6d305f237740ca4d27f05b91 100644 (file)
--- a/bundles/org.simantics.scl.runtime/src/org/simantics/scl/runtime/utils/AsyncUtils.java
+++ b/bundles/org.simantics.scl.runtime/src/org/simantics/scl/runtime/utils/AsyncUtils.java
@@ -2,6 +2,8 @@ package org.simantics.scl.runtime.utils;
 
 import java.io.PrintWriter;
 import java.io.StringWriter;
+import java.util.Arrays;
+import java.util.List;
 
 import org.simantics.scl.runtime.SCLContext;
 import org.simantics.scl.runtime.function.Function;
@@ -27,4 +29,8 @@ public class AsyncUtils {
             }
         }.start();
     }
+    
+    public static List<Object> pmap(Function f, List<Object> l) {
+        return Arrays.asList(l.parallelStream().map(a -> f.apply(a)).toArray());
+    }
 }