concurrent test

whatsmars-common/src/test/java/org/hongxi/java/util/concurrent/CompletableFutureTest.java

@@ -0,0 +1,16 @@
+package org.hongxi.java.util.concurrent;
+
+import java.util.concurrent.CompletableFuture;
+
+/**
+ * @author shenhongxi 2019/8/13
+ */
+public class CompletableFutureTest {
+
+    public static void main(String[] args) {
+        CompletableFuture.supplyAsync(() -> 1)
+                .thenApply(i -> i + 1)
+                .thenApply(i -> i * i)
+                .whenComplete((r, e) -> System.out.println(r));
+    }
+}

whatsmars-common/src/test/java/org/hongxi/java/util/concurrent/LockSupportTest.java

@@ -0,0 +1,26 @@
+package org.hongxi.java.util.concurrent;
+
+import java.util.concurrent.locks.LockSupport;
+
+/**
+ * @author shenhongxi 2019/8/13
+ */
+public class LockSupportTest {
+
+    public static void main(String[] args) {
+        Object blocker = new Object();
+        Thread t = new Thread(() -> {
+            System.out.println(System.currentTimeMillis());
+            LockSupport.park(blocker);
+            System.out.println(System.currentTimeMillis());
+        });
+        t.start();
+
+        try {
+            Thread.sleep(3000);
+        } catch (InterruptedException e) {
+            e.printStackTrace();
+        }
+        LockSupport.unpark(t);
+    }
+}

whatsmars-common/src/test/java/org/hongxi/java/util/concurrent/PhaserTest.java

@@ -0,0 +1,55 @@
+package org.hongxi.java.util.concurrent;
+
+import java.util.concurrent.Phaser;
+
+/**
+ * @author shenhongxi 2019/8/13
+ * @see java.util.concurrent.CountDownLatch
+ * @see java.util.concurrent.CyclicBarrier
+ */
+public class PhaserTest {
+
+    public static void main(String[] args) {
+        int swimmers = 6;
+        Phaser phaser = new SwimmingPhaser();
+        phaser.register();
+        for (int i = 0; i < swimmers; i++) {
+            phaser.register();
+            new Thread(new Swimmer(phaser), "swimmer" + i).start();
+        }
+        phaser.arriveAndDeregister();
+
+        while (!phaser.isTerminated()) { }
+        System.out.println("比赛结束");
+    }
+
+    static class SwimmingPhaser extends Phaser {
+        private int phaseToTerminate = 2;
+
+        @Override
+        protected boolean onAdvance(int phase, int registeredParties) {
+            System.out.println("*第" + phase + "阶段完成*");
+            return phase == phaseToTerminate || registeredParties == 0;
+        }
+    }
+
+    static class Swimmer implements Runnable {
+        Phaser phaser;
+
+        Swimmer(Phaser phaser) {
+            this.phaser = phaser;
+        }
+
+        @Override
+        public void run() {
+            System.out.println("游泳选手" + Thread.currentThread().getName() + "已到达赛场");
+            phaser.arriveAndAwaitAdvance();
+
+            System.out.println("游泳选手" + Thread.currentThread().getName() + "已准备好");
+            phaser.arriveAndAwaitAdvance();
+
+            System.out.println("游泳选手"+Thread.currentThread().getName()+"完成比赛");
+            phaser.arriveAndAwaitAdvance();
+        }
+    }
+}