<link rel="stylesheet" href="https://js.how234.com/third-party/SyntaxHighlighter/shCoreDefault.css" type="text/css" /><script type="text/javascript" src="https://js.how234.com/third-party/SyntaxHighlighter/shCore.js"></script><script type="text/javascript"> SyntaxHighlighter.all(); </script>
很多朋友都想知道java future是什麼,下面就一起來了解一下吧~
Future代表一個異步計算的結果,並且它提供一些方法來讓調用者檢測異步過程是否完成,或者取得異步計算的結果,或者取消正在執行的異步任務。
public class Test { private static ExecutorService executorService = Executors.newSingleThreadExecutor(); public static void main(String[]args){ System.out.println("hello world"); Future<Integer>future = calcute(9); while (!future.isDone()){ try { Thread.sleep(100); } catch (InterruptedException e) { e.printStackTrace(); } finally { System.out.println("正在執行"); } } try { int result = future.get(); System.out.println("result = " + result); } catch (ExecutionException e) { e.printStackTrace(); } catch (InterruptedException e) { e.printStackTrace(); } } public static Future<Integer>calcute(Integer i) { return executorService.submit(() -> { Thread.sleep(1000); System.out.println("return future for " + i); return i *i; }); }}
一個簡單Future使用用例寫完,使用線程池+Callback+Future,完成了一個簡單的計算操作。
Future是一個接口,先看一下內部方法:
public interface Future<V> { boolean cancel(boolean var1); boolean isCancelled(); boolean isDone(); V get() throws ExecutionException, InterruptedException; V get(long var1, TimeUnit var3) throws ExecutionException, InterruptedException, TimeoutException;}
get()函數是返回計算結果,注意get會同步操作,沒有返回結果前,會阻塞線程。
get還有一個重載函數get(long var1, TimeUnit var3),第一個參數是時長,第二個是單位。
表示在多少時長內獲取結果,如果仍未返回,則拋出異常TimeoutException。
try{ int result2 = future2.get(1000, TimeUnit.MILLISECONDS);} catch(TimeoutException e) { e.printStackTrace();}
cancel(boolean) 表示是否取消該future,
不能在調用cancel(true)/cancel(false)後,調用get()函數,否則會拋出異常CancellationException
isCancelled()函數是判斷該future是否已取消
isDone()函數是判斷該future是否已完成
isDone()函數是實時狀態讀取,不會阻塞線程。
Callback
Callback 是一個接口,內部只有一個函數
@FunctionalInterfacepublic interface Callable<V> { V call() throws Exception;}