feat

Author: CodePrometheus

Future/Future.iml

@@ -7,5 +7,24 @@
     </content>
     <orderEntry type="inheritedJdk" />
     <orderEntry type="sourceFolder" forTests="false" />
+    <orderEntry type="module-library">
+      <library name="JUnit4">
+        <CLASSES>
+          <root url="jar://$MAVEN_REPOSITORY$/junit/junit/4.13.1/junit-4.13.1.jar!/" />
+          <root url="jar://$MAVEN_REPOSITORY$/org/hamcrest/hamcrest-core/1.3/hamcrest-core-1.3.jar!/" />
+        </CLASSES>
+        <JAVADOC />
+        <SOURCES />
+      </library>
+    </orderEntry>
+    <orderEntry type="module-library">
+      <library>
+        <CLASSES>
+          <root url="jar://$MAVEN_REPOSITORY$/org/projectlombok/lombok/1.18.20/lombok-1.18.20.jar!/" />
+        </CLASSES>
+        <JAVADOC />
+        <SOURCES />
+      </library>
+    </orderEntry>
   </component>
 </module>

Future/src/CompletableFutureUsage.java …ompletable/CompletableFutureUsage01.javaFuture/src/CompletableFutureUsage.java renamed to Future/src/completable/CompletableFutureUsage01.java Future/src/CompletableFutureUsage.java renamed to Future/src/completable/CompletableFutureUsage01.java

@@ -1,10 +1,12 @@
+package completable;
+
 import java.util.concurrent.*;
 
 /**
  * @Author: zzStar
  * @Date: 09-07-2021 22:23
  */
-public class CompletableFutureUsage {
+public class CompletableFutureUsage01 {
 
     public static void main(String[] args) throws ExecutionException, InterruptedException {
         ThreadPoolExecutor executor = new ThreadPoolExecutor(1, 20, 1L, TimeUnit.MINUTES,

Future/src/completable/CompletableFutureUsage02.java

@@ -0,0 +1,96 @@
+package completable;
+
+import org.junit.Test;
+
+import java.util.StringJoiner;
+import java.util.concurrent.CompletableFuture;
+
+/**
+ * @Author: zzStar
+ * @Date: 09-11-2021 11:38
+ */
+public class CompletableFutureUsage02 {
+
+    public static void sleepSecond(long second) {
+        try {
+            Thread.sleep(second * 1000);
+        } catch (InterruptedException e) {
+            e.printStackTrace();
+        }
+    }
+
+    public static void printMessage(String tag) {
+        String res = new StringJoiner("\t|\t")
+                .add(String.valueOf(System.currentTimeMillis()))
+                .add(String.valueOf(Thread.currentThread().getId()))
+                .add(Thread.currentThread().getName())
+                .add(tag).toString();
+        System.out.println(res);
+    }
+
+    @Test
+    public void supplyAsync() {
+        // supplyAsync开启
+        CompletableFuture<String> future = CompletableFuture.supplyAsync(() -> {
+            printMessage("First");
+            sleepSecond(2);
+            printMessage("Second");
+            sleepSecond(1);
+            return "done";
+        });
+        printMessage("Play");
+        printMessage(future.join());
+    }
+
+    @Test
+    public void thenCombine() {
+        // thenCombine合并
+        CompletableFuture<String> combine = CompletableFuture.supplyAsync(() -> {
+            printMessage("1");
+            sleepSecond(1);
+            return "1";
+        }).thenCombine(CompletableFuture.supplyAsync(() -> {
+            printMessage("2");
+            sleepSecond(2);
+            return "2";
+        }), (a, b) -> {
+            System.out.println("a = " + a);
+            System.out.println("b = " + b);
+            return String.format("%s + %s", a, b);
+        });
+        printMessage("3");
+        printMessage(combine.join());
+    }
+
+    @Test
+    public void thenApply() {
+        // 相当于stream().map()
+        CompletableFuture<String> apply = CompletableFuture.supplyAsync(() -> {
+            printMessage("over");
+            sleepSecond(1);
+            return "1";
+            // thenApplyAsync会将后面的代码块当作一个独立的任务并且创建新的线程执行
+        }).thenApply(res -> {
+            printMessage(res + " -> res");
+            sleepSecond(2);
+            return "2";
+        });
+        printMessage("3");
+        printMessage(apply.join());
+    }
+
+    @Test
+    public void applyToEither() {
+        CompletableFuture<String> apply = CompletableFuture.supplyAsync(() -> {
+            printMessage("1");
+            sleepSecond(3);
+            return "1";
+        }).applyToEither(CompletableFuture.supplyAsync(() -> {
+            printMessage("2");
+            sleepSecond(2);
+            return "2";
+        }), res -> res);
+        printMessage(apply.join());
+    }
+
+}

Future/src/FutureAnalysis.java Future/src/future/FutureAnalysis.javaFuture/src/FutureAnalysis.java renamed to Future/src/future/FutureAnalysis.java

@@ -1,3 +1,5 @@
+package future;
+
 /**
  * @Author: zzStar
  * @Date: 10-13-2020 09:34

Future/src/FutureTaskUsage.java Future/src/future/FutureTaskUsage.javaFuture/src/FutureTaskUsage.java renamed to Future/src/future/FutureTaskUsage.java

@@ -1,3 +1,5 @@
+package future;
+
 import java.util.concurrent.*;
 
 /**

Future/src/GetException.java Future/src/future/GetException.javaFuture/src/GetException.java renamed to Future/src/future/GetException.java

@@ -1,3 +1,5 @@
+package future;
+
 import java.util.concurrent.*;
 
 /**

Future/src/MultiFutures.java Future/src/future/MultiFutures.javaFuture/src/MultiFutures.java renamed to Future/src/future/MultiFutures.java

@@ -1,3 +1,5 @@
+package future;
+
 import java.util.ArrayList;
 import java.util.Random;
 import java.util.concurrent.*;

Future/src/OneFuture.java Future/src/future/OneFuture.javaFuture/src/OneFuture.java renamed to Future/src/future/OneFuture.java

@@ -1,3 +1,5 @@
+package future;
+
 import java.util.Random;
 import java.util.concurrent.*;
 

…ure/src/RunnableCantThrowsException.java …/future/RunnableCantThrowsException.javaFuture/src/RunnableCantThrowsException.java renamed to Future/src/future/RunnableCantThrowsException.java Future/src/RunnableCantThrowsException.java renamed to Future/src/future/RunnableCantThrowsException.java

@@ -1,3 +1,5 @@
+package future;
+
 /**
  * 在run方法中无法抛出checked Exception
  * <p>

Future/src/Timeout.java Future/src/future/Timeout.javaFuture/src/Timeout.java renamed to Future/src/future/Timeout.java

@@ -1,3 +1,5 @@
+package future;
+
 import java.util.concurrent.*;
 
 /**