無線程池實現(xiàn)

while(存在未對賬訂單){// 查詢未對賬訂單Thread T1 = new Thread(()->{pos = getPOrders();});T1.start();// 查詢派送單Thread T2 = new Thread(()->{dos = getDOrders();});T2.start();// 等待 T1、T2 結(jié)束T1.join();T2.join();// 執(zhí)行對賬操作diff = check(pos, dos);// 差異寫入差異庫save(diff); }

線程池+CountDownLatch實現(xiàn)

// 創(chuàng)建 2 個線程的線程池 Executor executor = Executors.newFixedThreadPool(2); while(存在未對賬訂單){// 計數(shù)器初始化為 2CountDownLatch latch = new CountDownLatch(2);// 查詢未對賬訂單executor.execute(()-> {pos = getPOrders();latch.countDown();});// 查詢派送單executor.execute(()-> {dos = getDOrders();latch.countDown();});// 等待兩個查詢操作結(jié)束latch.await();// 執(zhí)行對賬操作diff = check(pos, dos);// 差異寫入差異庫save(diff); }

?

總結(jié)

以上是生活随笔為你收集整理的Java并发编程实战~CountDownLatch的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯，歡迎將生活随笔推薦給好友。