詳解一道京東面試題

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

面試題目描述

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

第一次思考

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

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

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

并發(fā)代碼

建議用PC端查看，所有代碼都可直接復(fù)制運(yùn)行，代碼中重要的點(diǎn)都有詳細(xì)注釋

1. 首先，我們先定義這三個(gè)接口

public class DoService { //設(shè)置A?B?C接口的返回值,b接口設(shè)置的是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被打斷??耗時(shí)" +?(System.currentTimeMillis()?-?start));
???????????????e.printStackTrace();
????????}
????????System.out.println("a耗時(shí)??"+(System.currentTimeMillis()?-?start)); return flagA;
????} public static boolean B() { long start?=?System.currentTimeMillis(); try {
????????????Thread.sleep(5000L);
????????} catch (InterruptedException?e)?{
????????????System.out.println("b被打斷??耗時(shí)" +?(System.currentTimeMillis()?-?start));
????????????e.printStackTrace();
????????}
????????System.out.println("b耗時(shí)??"+(System.currentTimeMillis()?-?start)); return flagB;
????} public static boolean C() { long start?=?System.currentTimeMillis(); try {
????????????Thread.sleep(8000L);
????????} catch (InterruptedException?e)?{
????????????System.out.println("c被打斷??耗時(shí)" +?(System.currentTimeMillis()?-?start));
????????????e.printStackTrace();
????????}
????????System.out.println("c耗時(shí)??"+(System.currentTimeMillis()?-?start)); return flagC;
????}
}

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

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 { //?標(biāo)記?返回值，代表這個(gè)接口是否執(zhí)行成功 Boolean?flag?= false; //記錄接口名字 String?serviceName?= null; //根據(jù)i的值來判斷調(diào)用哪個(gè)接口 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("當(dāng)前線程是:?"+Thread.currentThread().getName()+"正在處理的任務(wù)是:?"+this.taskName+"調(diào)用的接口是:?"+serviceName); return flag;
????}
}

1. 最后，我們定義一個(gè)測(cè)試類

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

1. 我們看下輸出結(jié)果

等待處理結(jié)果。。。
a耗時(shí) 3000 當(dāng)前線程是:?pool-1-thread-1正在處理的任務(wù)是:?任務(wù)1調(diào)用的接口是:?A
b耗時(shí) 5000 當(dāng)前線程是:?pool-1-thread-2正在處理的任務(wù)是:?任務(wù)2調(diào)用的接口是:?B
c耗時(shí) 8000 當(dāng)前線程是:?pool-1-thread-3正在處理的任務(wù)是:?任務(wù)3調(diào)用的接口是:?C
線程池+結(jié)果處理時(shí)間：8008 不合格

• 我們運(yùn)行的時(shí)候會(huì)發(fā)現(xiàn)，它的輸出結(jié)果的順序如下 1 2 3 4 5 我們圖中的2，3，4是再線程池內(nèi)開了三個(gè)線程執(zhí)行的，他們之間相隔一段時(shí)間才出現(xiàn)的，因?yàn)槊總€(gè)接口都有執(zhí)行時(shí)間

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

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

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

和京東面試官探討

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

靈光乍現(xiàn)

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

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被打斷??耗時(shí)" +?(System.currentTimeMillis()?-?start));
???????????????e.printStackTrace();
????????}
????????System.out.println("a耗時(shí)??"+(System.currentTimeMillis()?-?start)); return flagA;
????} public static boolean B() { long start?=?System.currentTimeMillis(); try {
????????????Thread.sleep(5000L);
????????} catch (InterruptedException?e)?{
????????????System.out.println("b被打斷??耗時(shí)" +?(System.currentTimeMillis()?-?start));
????????????e.printStackTrace();
????????}
????????System.out.println("b耗時(shí)??"+(System.currentTimeMillis()?-?start)); return flagB;
????} public static boolean C() { long start?=?System.currentTimeMillis(); try {
????????????Thread.sleep(8000L);
????????} catch (InterruptedException?e)?{
????????????System.out.println("c被打斷??耗時(shí)" +?(System.currentTimeMillis()?-?start));
????????????e.printStackTrace();
????????}
????????System.out.println("c耗時(shí)??"+(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();
???????} //如果有一個(gè)為false if (!flag){ //就把共享標(biāo)志位置為false Test.end?= false;
????????}else { //計(jì)數(shù)器加一，到三的話就是三個(gè)都為true Test.count.incrementAndGet();
???????}
????????System.out.println("當(dāng)前線程是:?"+Thread.currentThread().getName()+"正在處理的任務(wù)是:?"+this.name+"調(diào)用的接口是:?"+serviceName);
????}
}

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

}

main主線程開始掛起
a耗時(shí) 3024 當(dāng)前線程是:?Thread-0正在處理的任務(wù)是:?A調(diào)用的接口是:?A
b耗時(shí) 5000 當(dāng)前線程是:?Thread-1正在處理的任務(wù)是:?B調(diào)用的接口是:?B
c被打斷??耗時(shí)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耗時(shí) 5003 當(dāng)前線程是:?Thread-2正在處理的任務(wù)是:?C調(diào)用的接口是:?C
main?主線獲得結(jié)果后繼續(xù)執(zhí)行5014