詳解一道京東面試題

多線程并發(fā)執(zhí)行？線程之間通信？這是我偶爾聽到我同事做面試官時問的一道題，感覺很有意思，發(fā)出來大家和大家討論下

面試題目描述

現(xiàn)在呢,我們有三個接口，就叫他A,B,C吧，這三個接口都是查詢某個人征信信息的，必須同時返回true,我們才認為這個人的征信合格，如果其中某一個返回false的話，就表明這個人的征信不合格，如果是你，你會怎么設計怎么寫這個代碼呢？

第一次思考

首先，一定是并發(fā)執(zhí)行，假如說A接口執(zhí)行3秒，B接口執(zhí)行5秒，C接口執(zhí)行8秒的話

• 串行執(zhí)行： 3+5+8 = 16秒
• 并發(fā)執(zhí)行： 8=8秒 （時間最久的那個接口執(zhí)行的時間就是這三個接口的執(zhí)行總時間）

熟悉的感覺，多線程執(zhí)行任務，我在第二章文章實戰(zhàn)！xhJaver竟然用線程池優(yōu)化了。。。有提過怎么寫，感興趣的讀者可以回去看一下，不過我在這里再寫一下，話不多說來看下代碼

并發(fā)代碼

建議用PC端查看，所有代碼都可直接復制運行，代碼中重要的點都有詳細注釋

1. 首先，我們先定義這三個接口

public class DoService { //設置A?B?C接口的返回值,b接口設置的是false private static Boolean?flagA?= true; private static Boolean?flagB?= false; private static Boolean?flagC?= true; public static boolean A(){ long start?=?System.currentTimeMillis(); try {
????????????Thread.sleep(3000L);
????????} catch (InterruptedException?e)?{
????????????System.out.println("a被打斷??耗時" +?(System.currentTimeMillis()?-?start));
???????????????e.printStackTrace();
????????}
????????System.out.println("a耗時??"+(System.currentTimeMillis()?-?start)); return flagA;
????} public static boolean B() { long start?=?System.currentTimeMillis(); try {
????????????Thread.sleep(5000L);
????????} catch (InterruptedException?e)?{
????????????System.out.println("b被打斷??耗時" +?(System.currentTimeMillis()?-?start));
????????????e.printStackTrace();
????????}
????????System.out.println("b耗時??"+(System.currentTimeMillis()?-?start)); return flagB;
????} public static boolean C() { long start?=?System.currentTimeMillis(); try {
????????????Thread.sleep(8000L);
????????} catch (InterruptedException?e)?{
????????????System.out.println("c被打斷??耗時" +?(System.currentTimeMillis()?-?start));
????????????e.printStackTrace();
????????}
????????System.out.println("c耗時??"+(System.currentTimeMillis()?-?start)); return flagC;
????}
}

1. 其次 我們先創(chuàng)造一個Task 任務類

public class Task implements Callable<Boolean> { private String?taskName; private Integer?i; public Task(String?taskName,int i){ this.taskName?=taskName; this.i?=?i;
????} @Override public Boolean call() throws Exception { //?標記?返回值，代表這個接口是否執(zhí)行成功 Boolean?flag?= false; //記錄接口名字 String?serviceName?= null; //根據(jù)i的值來判斷調用哪個接口 if (i==1){
????????????flag???=????DoService.A();
????????????serviceName="A";
????????} if (i==2){
????????????flag???=????DoService.B();
????????????serviceName="B";
????????} if (i==3){
????????????flag???=????DoService.C();
????????????serviceName="C";
????????}
????????System.out.println("當前線程是:?"+Thread.currentThread().getName()+"正在處理的任務是:?"+this.taskName+"調用的接口是:?"+serviceName); return flag;
????}
}

1. 最后，我們定義一個測試類

class Test { public static void main(String[]?args) throws ExecutionException,?InterruptedException { //創(chuàng)建一個包含三個線程的線程池 ExecutorService?executorService?=?Executors.newFixedThreadPool(3); //事先準備好儲存結果的list集合 List< Future>?list?= new ArrayList<>(); //開始計時 long start?=?System.currentTimeMillis(); for (int i=1;i<4;i++){
????????????Task?task?= new Task("任務"+i,i); //將每個任務提交到線程池中，并且得到這個線程的執(zhí)行結果 Futureresult?=?executorService.submit(task);
????????????list.add(result);
????????} //記得把線程池關閉 executorService.shutdown(); //定義一個變量?0 int count?= 0;
????????System.out.println("等待處理結果。。。"); for (int i=0;i//得到處理的結果?線程阻塞，如果線程沒有處理完就一直阻塞 Boolean?flag?=?result.get(); //如果這個接口返回true,那么count就++ if (flag){
????????????????count++;
????????????}
????????}
????????System.out.println("線程池+結果處理時間："+?(System.currentTimeMillis()?-?start)); //如果count數(shù)量為3，那么三個就都為true,代表這個人征信沒問題 if (count==3){
????????????System.out.println("合格");
????????}else {//否則，就是有問題 System.out.println("不合格");
????????}
????}
}

1. 我們看下輸出結果

等待處理結果。。。
a耗時 3000 當前線程是:?pool-1-thread-1正在處理的任務是:?任務1調用的接口是:?A
b耗時 5000 當前線程是:?pool-1-thread-2正在處理的任務是:?任務2調用的接口是:?B
c耗時 8000 當前線程是:?pool-1-thread-3正在處理的任務是:?任務3調用的接口是:?C
線程池+結果處理時間：8008 不合格

• 我們運行的時候會發(fā)現(xiàn)，它的輸出結果的順序如下 1 2 3 4 5 我們圖中的2，3，4是再線程池內開了三個線程執(zhí)行的，他們之間相隔一段時間才出現(xiàn)的，因為每個接口都有執(zhí)行時間

程序運行后，“標記2”是3秒后出現(xiàn)，“標記三”是5秒后出現(xiàn)，“標記4”是8秒后出現(xiàn)

其實4和5相差時間很短，幾乎是同時出現(xiàn)的，因為4執(zhí)行完了就是主線程繼續(xù)執(zhí)行了

線程池+結果處理的時間一共是8秒，而每個接口分別執(zhí)行的時間是3秒，5秒，8秒，達到了我們所說的，多線程處理多個接口，總共耗時時間是耗時最長的接口的時間

和京東面試官探討

波哥說（我愛叫他波哥，東北人，說話則逗，幽默的人簡直就是人間瑰寶，其實我也蠻有趣的，就是沒人發(fā)現(xiàn)），你這程序不行啊，有個缺點，假如說，你這個A接口，耗時三秒，他返回了false,那么你另外兩個線程也不用執(zhí)行了，這個人的征信已經(jīng)不合格了，你需要判斷下，如果某一個線程執(zhí)行的任務返回了false,那么就及時中斷其他兩個線程

靈光乍現(xiàn)

上一次的代碼已經(jīng)實現(xiàn)了多線程執(zhí)行任務，可是這線程間通信怎么辦呢？怎么才能根據(jù)一個線程的執(zhí)行結果而打斷其他線程呢？我想到了以下幾點

1. 共享變量 public static volatile boolean end = true;

public class DoService { private static Boolean?flagA?= true; private static Boolean?flagB?= false; private static Boolean?flagC?= true; public static boolean A(){ long start?=?System.currentTimeMillis(); try {
????????????Thread.sleep(3000L);
????????} catch (InterruptedException?e)?{
????????????System.out.println("a被打斷??耗時" +?(System.currentTimeMillis()?-?start));
???????????????e.printStackTrace();
????????}
????????System.out.println("a耗時??"+(System.currentTimeMillis()?-?start)); return flagA;
????} public static boolean B() { long start?=?System.currentTimeMillis(); try {
????????????Thread.sleep(5000L);
????????} catch (InterruptedException?e)?{
????????????System.out.println("b被打斷??耗時" +?(System.currentTimeMillis()?-?start));
????????????e.printStackTrace();
????????}
????????System.out.println("b耗時??"+(System.currentTimeMillis()?-?start)); return flagB;
????} public static boolean C() { long start?=?System.currentTimeMillis(); try {
????????????Thread.sleep(8000L);
????????} catch (InterruptedException?e)?{
????????????System.out.println("c被打斷??耗時" +?(System.currentTimeMillis()?-?start));
????????????e.printStackTrace();
????????}
????????System.out.println("c耗時??"+(System.currentTimeMillis()?-?start)); return flagC;
????}
}

public class Task implements Runnable { private String?name?; public Task(?String?name){ this.name?=?name;
????} @Override public void run() { boolean flag?= false;
????????String?serviceName?= null; if(this.name.equals("A")){
????????????serviceName?= "A";
?????????????flag?=?DoService.A();
????????} if(this.name.equals("B")){
????????????serviceName?= "B";
????????????flag?=?DoService.B();
????????} if(this.name.equals("C")){
???????????serviceName?= "C";
???????????flag?=?DoService.C();
???????} //如果有一個為false if (!flag){ //就把共享標志位置為false Test.end?= false;
????????}else { //計數(shù)器加一，到三的話就是三個都為true Test.count.incrementAndGet();
???????}
????????System.out.println("當前線程是:?"+Thread.currentThread().getName()+"正在處理的任務是:?"+this.name+"調用的接口是:?"+serviceName);
????}
}

class Test { //設置countDownLatch?里面計數(shù)為1， //?只調用一次countDownLatch.countDown就可以繼續(xù)執(zhí)行?countDownLatch.await(); //后面的代碼了，接觸阻塞 public static CountDownLatch?countDownLatch?= new CountDownLatch(1); //默認都為true,有一個線程為false了，那么就變?yōu)閒alse public static volatile boolean end?= true; //計數(shù)器，數(shù)字變?yōu)?的時候代表三個接口都返回true,線程安全的原子類 public static AtomicInteger?count?=new AtomicInteger(0); public static void main(String[]?args) throws InterruptedException { long start?=?System.currentTimeMillis(); //創(chuàng)建三個任務，分被調用A?B?C?接口 Task?taskA?= new Task("A");
????????Task?taskB?= new Task("B");
????????Task?taskC?= new Task("C"); //創(chuàng)建三個線程 Thread?tA?= new Thread(taskA);
????????Thread?tB?= new Thread(taskB);
????????Thread?tC?= new Thread(taskC); //開啟三個線程 tA.start();
????????tB.start();
????????tC.start(); //在開啟一個線程，這個線程就是單獨循環(huán)掃描這個共享變量的 new Thread(new Runnable()?{ @Override public void run() { //此線程一直循環(huán)判斷這個結束變量，如果為false的話，就代表有一個接口返回false,跳出，重點其他線程 while (true){ if (!end?){ //當這個共享變量為false時i表示，其他線程可以中斷了，所以就打斷他們執(zhí)行 tA.interrupt();
????????????????????????tB.interrupt();
????????????????????????tC.interrupt(); //如果某個線程被打斷的話，就表明不合格 System.out.println("不合格"); //countDownLatch?計數(shù)器減一 countDownLatch.countDown(); break;
????????????????????} if (Test.count.get()==3){
????????????????????????System.out.println("合格"); //countDownLatch?計數(shù)器減一 countDownLatch.countDown(); break;
????????????????????}
????????????????}
????????????}
????????}).start();
????????System.out.println(Thread.currentThread().getName()+"主線程開始掛起"); //阻塞主線程繼續(xù)執(zhí)行，等待其他線程計算完結果在執(zhí)行下去，countDownLatch中的計數(shù)為0時，就可以繼續(xù)執(zhí)行下去 countDownLatch.await();
????????System.out.println(Thread.currentThread().getName()+"?主線獲得結果后繼續(xù)執(zhí)行"+(System.currentTimeMillis()?-?start));
????}

}

main主線程開始掛起
a耗時 3024 當前線程是:?Thread-0正在處理的任務是:?A調用的接口是:?A
b耗時 5000 當前線程是:?Thread-1正在處理的任務是:?B調用的接口是:?B
c被打斷??耗時5001 不合格
java.lang.InterruptedException:?sleep?interrupted
?at?java.lang.Thread.sleep(Native?Method)
?at?com.xhj.concurrent.executor_05._02.DoService.C(DoService.java:41)
?at?com.xhj.concurrent.executor_05._02.Task.run(Task.java:30)
?at?java.lang.Thread.run(Thread.java:748)
c耗時 5003 當前線程是:?Thread-2正在處理的任務是:?C調用的接口是:?C
main?主線獲得結果后繼續(xù)執(zhí)行5014