1、使用線程包
java.util.concurrent.Future
2、Future代表一個異步計算的結果。
它提供了方法來檢查是否計算已經完成，還是正在計算而處於等待狀態，並且也提供了獲取計算結果 方法。當計算完成后，只能通過get方法來獲取執行結果，必要的話該方法會阻塞。通過cancel方法可以取消計算。一旦計算已經完成，便無法取消。
主要方法：
cancel()：取消任務
get()：等待任務執行完成，並獲取執行結果
get(long timeout, TimeUnit unit)：在指定的時間內會等待任務執行，超時則拋異常。
3、示例代碼
1 package Concurrent; 2
3 import java.util.concurrent.*; 4
5 /** 6 * 測試方法的超時時間 7 */
8 public class FutureTest { 9
10 public static void functionTimeoutTest2() throws Exception{ 11 ExecutorService executorService= Executors.newSingleThreadExecutor(); 12 Future<String> future=executorService.submit(()->
13 { 14 Thread.sleep(10000); 15 return "success"; 16 } 17 ); 18
19 try{ 20 String result=future.get(5,TimeUnit.SECONDS); 21 //String result=future.get(50,TimeUnit.SECONDS);
22 System.out.println("result:"+result); 23 } 24 catch (TimeoutException e){ 25 System.out.println("超時了!"); 26 } 27 } 28 }
如果是java8以前的，可以使用下面這段代碼：
1 package Concurrent; 2
3 import java.util.concurrent.*; 4
5 /** 6 * 測試方法的超時時間 7 */
8 public class FutureTest { 9
10 public static void functionTimeoutTest() throws Exception{ 11 //java8建議使用lambda表達式來替代匿名內部類
12 Callable<String> task=new Callable<String>() { 13 @Override 14 public String call() throws Exception { 15 Thread.sleep(10000); 16 return "success"; 17 } 18 }; 19
20 ExecutorService executorService= Executors.newSingleThreadExecutor(); 21 Future<String> future=executorService.submit(task); 22 try{ 23 String result=future.get(5,TimeUnit.SECONDS); 24 //String result=future.get(50,TimeUnit.SECONDS);
25 System.out.println("result:"+result); 26 } 27 catch (TimeoutException e){ 28 System.out.println("超時了!"); 29 } 30 } 31 }
4、Callable
Callable相當於Runnable,所以，這里實現的是一個線程，但是與Runnable不同的是，它是具有返回值的，這個返回值就是我們想要任務返回的結果，比如說，我們想要任務返回的是一個提示信息，那么，返回值可以是String,然后在我們要實現的call()方法中return一句提示信息，接着只要使用Future類的get()方法，就可以從里面得到提示信息了，只要任務完成。所以，由此我們可以知道，java SE5比起以前來，在並發這方面做了更多的工作，它完善了我們的並發線程機制，使我們可以更好的根據任務的完成情況來進行與其他任務的協作，比如說，我們可以通過Future的返回值來決定是否終止任務，或者開啟另一個任務。任務的終止可以使用Future的方法future.cancel(boolean),其中boolean為true或false，來決定是否終止，至於開啟另一個任務，可以重新開啟另一個線程，但是這里就馬上有個問題浮現出來，就是當Futrue的結果返回來時，該任務有沒有結束呢？因為這時一定已經執行完該任務的call()方法。是的，該任務已經結束了，只是我們沒有取出它的返回結果而已。
5、更進一步：使用FutureTask
FutureTask既實現Runnable又實現Callable，現在我們可以這樣做：
1 public static void functionTimeoutTest3() throws Exception{ 2 ExecutorService executorService= Executors.newSingleThreadExecutor(); 3 FutureTask<String> future=new FutureTask<>(()->
4 { 5 Thread.sleep(10000); 6 return "success"; 7 } 8 ); 9 executorService.execute(future); 10
11 try{ 12 String result=future.get(5,TimeUnit.SECONDS); 13 //String result=future.get(50,TimeUnit.SECONDS);
14 System.out.println("result:"+result); 15 } 16 catch (TimeoutException e){ 17 System.out.println("超時了!"); 18 } 19 }
這里就是FutureTask的一般用法，它最大的好處就是我們可以將任務交給執行器后執行其他操作，然后再從里面得到任務的結果。這里必須要注意，只有FutureTask這種既實現Runnable又實現Callable才能夠通過executor()遞交給ExecutorService,而Future不行，只能通過submit()，因為executor()要求的參數是一個實現了Runnable的類。