Java線程池（Callable+Future模式）
阿新 • • 發佈：2018-11-14
ted class 最大並發數 catch tst wrap [] 當前 周期性 Java線程池（Callable+Future模式）
Java通過Executors提供四種線程池
1)newCachedThreadPool創建一個可緩存線程池，如果線程池長度超過處理需要，可靈活回收空閑線程，若無可回收，則新建線程。
2)newFixedThreadPool 創建一個定長線程池，可控制線程最大並發數，超出的線程會在隊列中等待。
3)newScheduledThreadPool 創建一個定長線程池，支持定時及周期性任務執行。
4)newSingleThreadExecutor 創建一個單線程化的線程池，它只會用唯一的工作線程來執行任務，保證所有任務按照指定順序(FIFO, LIFO, 優先級)執行。
public class chuju implements Callable<Boolean>{ @Override public Boolean call() throws Exception { try{ System.out.println("買廚具"); Thread.sleep(3000); System.out.println(2)shicai"買好廚具"); }catch (InterruptedException e){ e.printStackTrace(); } return true; } }
public class shicai implements Callable<Boolean>{ @Override public Boolean call() throws Exception { try{ System.out.println("買食材"); Thread.sleep(1000); System.out.println("買好食材"); }catch(InterruptedException e){ e.printStackTrace(); } return true; } }3)zuofan
public class zuofan implements Callable<Boolean>{ @Override public Boolean call() throws Exception { try{ System.out.println("做飯"); Thread.sleep(5000); System.out.println("做好飯"); }catch (InterruptedException e){ e.printStackTrace(); } return true; } }4)Main
public class Main { public static void main(String[] args) { ExecutorService es = Executors.newCachedThreadPool(); chuju cj = new chuju(); shicai sc = new shicai(); Future<Boolean> f1 = es.submit(cj); Future<Boolean> f2 = es.submit(sc); try{ Boolean b1 = f1.get();//會阻塞當前線程 Boolean b2 = f2.get(); System.out.println(b1); System.out.println(b2); if(b1 && b2){ zuofan zf = new zuofan(); es.submit(zf); } }catch(InterruptedException e){ e.printStackTrace(); }catch (ExecutionException e){ e.printStackTrace(); } es.shutdown(); } }5)執行結果 Connected to the target VM, address: ‘127.0.0.1:57304‘, transport: ‘socket‘ 買廚具 買食材 買好食材 買好廚具 true true 做飯 Disconnected from the target VM, address: ‘127.0.0.1:57304‘, transport: ‘socket‘ 做好飯 Process finished with exit code 0 從運行結果可以看出，買出具代碼和買食材代碼是異步執行的，這兩個都執行完畢後，才執行的做飯代碼。那麽為什麽子線程zuofan沒有先執行呢？由於Future的get()方法沒有得到返回值，讓當前線程暫時掛起了。 註意：Future的get()方法，如果拿不到結果會阻塞當前線程。
Java線程池（Callable+Future模式）