<dependency>
    <groupId>com.google.guava</groupId>
    <artifactId>guava</artifactId>
    <version>32.1.3-jre</version>
</dependency>

public class ListenableFutureExample {
    public static void main(String[] args) {
        ExecutorService executorService = Executors.newSingleThreadExecutor();
        ListeningExecutorService listeningExecutorService = MoreExecutors.listeningDecorator(executorService);
        ListenableFuture<String> future = listeningExecutorService.submit(new Callable<String>() {
            @Override
            public String call() throws Exception {
                // 模擬異步任務(wù)
                Thread.sleep(2000);
                System.out.println(Thread.currentThread().getName() + ":異步任務(wù)執(zhí)行完畢");
                return "異步任務(wù)執(zhí)行成功：success";
            }
        });
        Futures.addCallback(future, new FutureCallback<String>() {
            @Override
            public void onSuccess(String result) {
                // 異步任務(wù)執(zhí)行成功后的回調(diào)方法
                System.out.println(Thread.currentThread().getName() + ":異步任務(wù)執(zhí)行成功，結(jié)果是：" + result);
                listeningExecutorService.shutdown();//收到回調(diào)結(jié)果后，建議關(guān)注線程池，否則監(jiān)聽(tīng)回調(diào)程序會(huì)一直阻塞，不會(huì)結(jié)束；
            }
            @Override
            public void onFailure(Throwable t) {
                // 異步任務(wù)執(zhí)行失敗后的回調(diào)方法
                System.out.println("異步任務(wù)執(zhí)行失敗");
                t.printStackTrace();
            }
        }, executorService);
        System.out.println(Thread.currentThread().getName() + ":主線程繼續(xù)執(zhí)行其他任務(wù)...");
    }
}

public class GuavaCountDownLatchExample {
    public static void main(String[] args) {
        int numberOfThreads = 3;
        CountDownLatch latch = new CountDownLatch(numberOfThreads);
        for (int i = 0; i < numberOfThreads; i++) {
            new Thread(new Worker(latch), "Thread" + i).start();
        }
        Uninterruptibles.awaitUninterruptibly(latch); // 使用Guava的Uninterruptibles類等待所有工作線程執(zhí)行完畢
        System.out.println("All worker threads have finished.");
    }
}


class Worker implements Runnable {
    private final CountDownLatch latch;


    Worker(CountDownLatch latch) {
        this.latch = latch;
    }
    @Override
    public void run() {
        try {
            System.out.println(Thread.currentThread().getName() + " is working.");
            Thread.sleep((long) (Math.random() * 1000)); // 模擬工作線程執(zhí)行的任務(wù)
            System.out.println(Thread.currentThread().getName() + " has finished.");
        } catch (InterruptedException e) {
            e.printStackTrace();
        } finally {
            latch.countDown(); // 工作線程完成任務(wù)后，計(jì)數(shù)器減一
        }
    }
}

public class CyclicBarrierExample {
    public static void main(String[] args) {
        final int totalThread = 10;
        CyclicBarrier cyclicBarrier = new CyclicBarrier(totalThread);


        for (int i = 0; i < totalThread; i++) {
            new Thread(new Task(cyclicBarrier), "Thread" + i).start();
        }
    }
}


class Task implements Runnable {
    private CyclicBarrier cyclicBarrier;


    public Task(CyclicBarrier cyclicBarrier) {
        this.cyclicBarrier = cyclicBarrier;
    }


    @Override
    public void run() {
        System.out.println(Thread.currentThread().getName() + " is ready");
        try {
            cyclicBarrier.await(); //等待其他線程到達(dá)屏障點(diǎn)
        } catch (Exception e) {
            e.printStackTrace();
        }
        System.out.println(Thread.currentThread().getName() + " is running");
    }
}