Added a new function pmap to Async module

[simantics/platform.git] / bundles / org.simantics.scl.runtime / src / org / simantics / scl / runtime / utils / AsyncUtils.java

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());
+    }
 }