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的類。

?

轉載于:https://www.cnblogs.com/gudi/p/8334594.html

總結

以上是生活随笔為你收集整理的Java使用Future设置方法超时的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。