第四周作业2：使用循环阻塞主线程直到拿到结果

chengfpvoid · chengfpvoid · commit 990b0b446694 · 2020-11-11T22:09:20.000+08:00
diff --git a/03concurrency/0301/src/main/java/java0/conc0303/Homework03.java b/03concurrency/0301/src/main/java/java0/conc0303/Homework03.java
@@ -1,6 +1,6 @@
 package java0.conc0303;
 
-import java.util.concurrent.CompletableFuture;
+import java.util.concurrent.atomic.AtomicReference;
 
 /**
  * &#26412;&#21608;&#20316;&#19994;&#65306;&#65288;&#24517;&#20570;&#65289;&#24605;&#32771;&#26377;&#22810;&#23569;&#31181;&#26041;&#24335;&#65292;&#22312;main&#20989;&#25968;&#21551;&#21160;&#19968;&#20010;&#26032;&#32447;&#31243;&#25110;&#32447;&#31243;&#27744;&#65292;
@@ -27,12 +27,17 @@ public static void main(String[] args) throws Exception {
         // });
         // executorService.shutdown();
         // countDownLatch.await();
-        int result = CompletableFuture.supplyAsync(()-> sum()).join();
+        //int result = CompletableFuture.supplyAsync(()-> sum()).join();
 
         //int result = sum(); //&#36825;&#26159;&#24471;&#21040;&#30340;&#36820;&#22238;&#20540;
         //int result = future.get();
+        AtomicReference<Integer> result = new AtomicReference<>();
+        new Thread(() -> result.set(sum())).start();
         // &#30830;&#20445;  &#25343;&#21040;result &#24182;&#36755;&#20986;
-        System.out.println("&#24322;&#27493;&#35745;&#31639;&#32467;&#26524;&#20026;&#65306;"+result);
+        while (result.get() == null) {
+
+        }
+        System.out.println("&#24322;&#27493;&#35745;&#31639;&#32467;&#26524;&#20026;&#65306;"+result.get());
 
         System.out.println("&#20351;&#29992;&#26102;&#38388;&#65306;" + (System.currentTimeMillis() - start) + " ms");
 
