Google Guava異步回調

在如下筆記中提到，無論是join還是FutureTask都會阻塞主線程，無法實現真正的異步處理

https://www.cnblogs.com/qq931399960/p/15555152.html

Guava可提供了一種異步回調方案，不會阻塞主線程，Guava中添加了幾個相關接口

FutureCallback: 主要對異步任務結束后的一些處理，在異步任務執行結束后被調用，包括onSuccess和onFailure兩個方法，前者在任務結束后調用，無論異步任務是否發生了異常，結束后都會調用onSuccess，接口名字中帶有Future，但和jdk中Future沒有關系。

ListeningExecutorService：guava自己的連接池，對jdk中ExecutorService的封裝

ListenableFuture：只有一個addListener接口，作用為將FutureCallback和異步任務綁定，使異步任務完成之后可以觸發FutureCallback，但一般不會直接使用addListener方法，可以通過ListeningExecutorService。submit方法獲取該接口對應的實現類對象，通過Futures的addCallback方法，將ListenableFuture和FutureCallback以及異步任務進行綁定。

使用Guava實現https://www.cnblogs.com/qq931399960/p/15555152.html中業務處理

    private final static Logger logger = LoggerFactory.getLogger(OrderMealPlatformGuava.class);
    static Boolean courierArrive = null; // 默認null表示當前線程還未執行結束。true/false為最終執行結果
    static Boolean merchantReadyMeal = null;

    public static void main(String[] args) {
        ThreadPoolExecutor pool = null;
        try {
            pool = new ThreadPoolExecutor(2, 2, 1000, TimeUnit.SECONDS, new ArrayBlockingQueue<Runnable>(4));
            ListeningExecutorService gpool = MoreExecutors.listeningDecorator(pool);

            ListenableFuture<Boolean> merchantFuture = gpool.submit(new Callable<Boolean>() {
                @Override
                public Boolean call() throws Exception {
                    try {
                        logger.info("起鍋燒油");
                        logger.info("炒菜");
                        // 5s炒菜時間
//                        int i =1/0; // 廚師請假
                        Thread.sleep(5000);
                        logger.info("盛飯");
                        logger.info("打包");
                    } catch (Exception e) {
                        logger.error("", e);
                        return false;
                    }
                    return true;
                }
            });

            ListenableFuture<Boolean> courierFuture = gpool.submit(new Callable<Boolean>() {
                @Override
                public Boolean call() throws Exception {
                    try {
                        logger.info("搶單");
                        logger.info("規划路線");
                        // 3s趕路時間
//                        int i=1/0; // 車子被偷
                        Thread.sleep(3000);
                        logger.info("趕路");
                        logger.info("到店");
                    } catch (Exception e) {
                        logger.error("", e);
                        return false;
                    }
                    return true;
                }
            });

            /*
             * 當異步任務失敗，該方法中onSuccess和onFailure都會被執行，前者指的是異步任務結束了，並不是指異步任務執行成功，
             * 異步任務的執行成功與否，需要根據onSuccess的參數result來確定
             */
            Futures.addCallback(merchantFuture, new FutureCallback<Boolean>() {

                @Override
                public void onSuccess(Boolean result) {
                    // 異步任務執行完成無論結果如何都會進入到該方法
                    // 走到這里，結束可能為true也可能為false，不能直接認為merchantReadyMeal=true
                    // result為異步任務的執行結果
                    merchantReadyMeal = result;
                    if (courierArrive != null) {
                        // 快遞員的流程已經結束
                        sendMeal(merchantReadyMeal, courierArrive);
                    }
                }

                @Override
                public void onFailure(Throwable t) {
                    // t為異步任務拋出的異常
                    logger.error("", t);
                }
            }, /* 使用公共的pool，也可以使用的新的pool */pool);

            Futures.addCallback(courierFuture, new FutureCallback<Boolean>() {

                @Override
                public void onSuccess(Boolean result) {
                    courierArrive = result;
                    // 處理成功時被調用
                    if (merchantReadyMeal != null) {
                        // 商家的流程已經結束
                        sendMeal(merchantReadyMeal, courierArrive);
                    }

                }

                @Override
                public void onFailure(Throwable t) {
                    logger.error("", t);
                }
            }, pool);

            logger.info("繼續發布訂單消息");
        } catch (Exception e) {
            logger.error("", e);
        } finally {
            while (true) {
                // getActiveCount返回的為正在執行任務的線程的數據，如果線程都未執行任務，則會返回0
                if (pool != null && pool.getActiveCount() == 0) {
                    // 對於本例中，需要所有線程執行完，才能結束線程池，並且也不會再有新任務添加，因此可以這么關閉
                    pool.shutdown();
                    break;
                }
                LockSupport.parkNanos(1000 * 1000 * 1000 * 1);
            }
            // 如果按照如下關閉線程池，則異步線程，則可能會出現異常
            // shutdownThreadPoolGracefully(pool);
        }

    }

    private static void sendMeal(boolean merchantResult, boolean courierResult) {
        if (merchantResult && courierResult) {
            logger.info("快遞員開始送餐 。。。");
        } else if (merchantResult && !courierResult) {
            logger.error("外賣員車子被偷了，不能夠送餐");
        } else if (!merchantResult && courierResult) {
            logger.error("商家廚師家里臨時有事，請假了，做不了飯");
        } else {
            logger.error("外賣員車子被偷，商家廚師請假了 。。。 ");
        }
    }

執行結果

18:20:46.719 [pool-1-thread-1] INFO com.demo.order.OrderMealPlatformGuava - 起鍋燒油
18:20:46.723 [main] INFO com.demo.order.OrderMealPlatformGuava - 繼續發布訂單消息
18:20:46.723 [pool-1-thread-1] INFO com.demo.order.OrderMealPlatformGuava - 炒菜
18:20:46.719 [pool-1-thread-2] INFO com.demo.order.OrderMealPlatformGuava - 搶單
18:20:46.723 [pool-1-thread-2] INFO com.demo.order.OrderMealPlatformGuava - 規划路線
18:20:49.723 [pool-1-thread-2] INFO com.demo.order.OrderMealPlatformGuava - 趕路
18:20:49.723 [pool-1-thread-2] INFO com.demo.order.OrderMealPlatformGuava - 到店
18:20:51.723 [pool-1-thread-1] INFO com.demo.order.OrderMealPlatformGuava - 盛飯
18:20:51.723 [pool-1-thread-1] INFO com.demo.order.OrderMealPlatformGuava - 打包
18:20:51.723 [pool-1-thread-1] INFO com.demo.order.OrderMealPlatformGuava - 快遞員開始送餐 。。。

 

從運行結果看，主線程在發布了訂單消息之后，就繼續再發布其他的訂單，不會因為前面的訂單沒有完成而阻塞