(一)
Callable和Runnable比較相似,都可以用來實現線程任務。但callable使用了泛型設計,使用一個V類型值,能夠
在執行結束后返回一個V類型的值。而Runable只會返回一個void,不能夠獲得執行的結果。
(二)
使用Callable要和Future類或者Futuretask類搭配使用,他們類似一種對線程執行任務的返回數據的操作的封裝類。
使用方法
1 Callable 和 future
首先寫一個Callable接口的實例,實現Call()方法,然后通過Thread或者線程池submit函數使用這個Callable實例,
futuretask不同于future,它進一步豐富了future的功能。futuretask實現了Runnalefuture接口,這是他具有了可以
被線程執行的能力。所以使用時直接可以把實例化好的Callable實例以參數的形式傳給它,然后就可以直接使用Thread
或者線程池submit函數操作它。在最后直接調用它的get函數就能獲得相應的返回結果,當然他還有很多其他的功能。
Callable和Runnable比較相似,都可以用來實現線程任務。但callable使用了泛型設計,使用一個V類型值,能夠
在執行結束后返回一個V類型的值。而Runable只會返回一個void,不能夠獲得執行的結果。
(二)
使用Callable要和Future類或者Futuretask類搭配使用,他們類似一種對線程執行任務的返回數據的操作的封裝類。
使用方法
1 Callable 和 future
首先寫一個Callable接口的實例,實現Call()方法,然后通過Thread或者線程池submit函數使用這個Callable實例,
將返回結果賦值給future類型的一個實例,然后就可以通過這個實例對返回的結果進行get查詢等操作
public class Test {public static void main(String[] args) {ExecutorService executor = Executors.newCachedThreadPool();Task task = new Task();Future<Integer> result = executor.submit(task);executor.shutdown();try {Thread.sleep(1000);} catch (InterruptedException e1) {e1.printStackTrace();}System.out.println("主線程在執行任務");try {System.out.println("task運行結果"+result.get());} catch (InterruptedException e) {e.printStackTrace();} catch (ExecutionException e) {e.printStackTrace();}System.out.println("所有任務執行完畢");}
}
class Task implements Callable<Integer>{@Overridepublic Integer call() throws Exception {System.out.println("子線程在進行計算");Thread.sleep(3000);int sum = 0;for(int i=0;i<100;i++)sum += i;return sum;}
}
futuretask不同于future,它進一步豐富了future的功能。futuretask實現了Runnalefuture接口,這是他具有了可以
被線程執行的能力。所以使用時直接可以把實例化好的Callable實例以參數的形式傳給它,然后就可以直接使用Thread
或者線程池submit函數操作它。在最后直接調用它的get函數就能獲得相應的返回結果,當然他還有很多其他的功能。
public class Test {public static void main(String[] args) {//第一種方式ExecutorService executor = Executors.newCachedThreadPool();Task task = new Task();FutureTask<Integer> futureTask = new FutureTask<Integer>(task);executor.submit(futureTask);executor.shutdown();//第二種方式,注意這種方式和第一種方式效果是類似的,只不過一個使用的是ExecutorService,一個使用的是Thread/*Task task = new Task();FutureTask<Integer> futureTask = new FutureTask<Integer>(task);Thread thread = new Thread(futureTask);thread.start();*/try {Thread.sleep(1000);} catch (InterruptedException e1) {e1.printStackTrace();}System.out.println("主線程在執行任務");try {System.out.println("task運行結果"+futureTask.get());} catch (InterruptedException e) {e.printStackTrace();} catch (ExecutionException e) {e.printStackTrace();}System.out.println("所有任務執行完畢");}
}
class Task implements Callable<Integer>{@Overridepublic Integer call() throws Exception {System.out.println("子線程在進行計算");Thread.sleep(3000);int sum = 0;for(int i=0;i<100;i++)sum += i;return sum;}
}