add some methods

Author: hackingwu

src/main/java/cn/hackingwu/promise/jdk8/IOPromise.java

@@ -1,5 +1,6 @@
 package cn.hackingwu.promise.jdk8;
 
+import java.util.concurrent.ExecutionException;
 import java.util.concurrent.Executor;
 import java.util.concurrent.ExecutorService;
 import java.util.concurrent.Executors;
@@ -9,6 +10,9 @@
 import java.util.concurrent.TimeUnit;
 import java.util.concurrent.atomic.AtomicInteger;
 import java.util.concurrent.atomic.AtomicLong;
+import java.util.function.Supplier;
+
+import static cn.hackingwu.promise.jdk8.Promise.all;
 
 /**
  * @Author: Jason Wu
@@ -52,4 +56,34 @@ public Thread newThread(Runnable r) {
         }
     }
 
+    public static Supplier getSupplier(int i){
+        return () -> {
+            System.out.println("supplier"+i+": "+Thread.currentThread().getId());
+            Supplier supplier1_1 = () ->{
+                System.out.println("supplier"+i+"_1: "+Thread.currentThread().getId());
+                return null;
+            };
+            Supplier supplier1_2 = () ->{
+                System.out.println("supplier"+i+"_2: "+Thread.currentThread().getId());
+                return null;
+            };
+            try {
+                Promise.all(supplier1_1, supplier1_2).get();
+            } catch (InterruptedException e) {
+                e.printStackTrace();
+            } catch (ExecutionException e) {
+                e.printStackTrace();
+            }
+            return null;
+        };
+    }
+
+    public static void main(String[] args){
+        Supplier supplier1 = getSupplier(1);
+        Supplier supplier2 = getSupplier(2);
+        Supplier supplier3 = getSupplier(3);
+
+        all(supplier1, supplier2, supplier3);
+    }
+
 }

src/main/java/cn/hackingwu/promise/jdk8/Promise.java

@@ -20,6 +20,23 @@ private static CompletableFuture[] supplyAsync(Supplier... suppliers){
         return futures;
     }
 
+    private static CompletableFuture[] runAsync(Runnable... runnables){
+        CompletableFuture[] futures = new CompletableFuture[runnables.length];
+        for (int i = 0; i < runnables.length; i++) {
+            futures[i] = CompletableFuture.runAsync(runnables[i], getExecutor());
+        }
+        return futures;
+    }
+
+    public static CompletableFuture all(Runnable... runnables){
+        return CompletableFuture.allOf(runAsync(runnables));
+    }
+
+    public static CompletableFuture any(Runnable... runnables){
+        return CompletableFuture.anyOf(runAsync(runnables));
+    }
+
+
     public static CompletableFuture all(Supplier... suppliers){
         return CompletableFuture.allOf(supplyAsync(suppliers));
     }