Java中Runnable和Callable的區(qū)別和聯(lián)系及使用場(chǎng)景
Java多線程有兩個(gè)重要的接口,Runnable和Callable,分別提供一個(gè)run方法和call方法,二者是有較大差異的。
1)Runnable提供run方法,無法通過throws拋出異常,所有CheckedException必須在run方法內(nèi)部處理。Callable提供call方法,直接拋出Exception異常。
2)Runnable的run方法無返回值,Callable的call方法提供返回值用來表示任務(wù)運(yùn)行的結(jié)果
3)Runnable可以作為Thread構(gòu)造器的參數(shù),通過開啟新的線程來執(zhí)行,也可以通過線程池來執(zhí)行。而Callable只能通過線程池執(zhí)行。
一、Runnable使用場(chǎng)景
1)作為Thread的構(gòu)造參數(shù)開啟新的線程,以下是常用的通過匿名內(nèi)部類的方式創(chuàng)建線程。
Thread thread = new Thread(new Runnable() { @Override public void run() { System.out.println("I am a runnable task"); } }); thread.start();
2)由于Java只提供單繼承,故創(chuàng)建線程時(shí)一般通過實(shí)現(xiàn)Runnable接口,來實(shí)現(xiàn)run方法的具體邏輯。然后實(shí)例化,作為Thread的構(gòu)造參數(shù)開啟線程。
class RunnableTask implements Runnable { @Override public void run() { System.out.println("I am a runnable task"); } }
main方法:
RunnableTask runnableTask = new RunnableTask(); Thread thread1 = new Thread(runnableTask); thread1.start();
其實(shí)1)和2)的本質(zhì)是一樣的。
3)作為線程任務(wù)提交給線程池,通過線程池維護(hù)的工作者線程來執(zhí)行。
ExecutorService executor = Executors.newCachedThreadPool(); RunnableTask runnableTask = new RunnableTask(); executor.execute(runnableTask); executor.shutdown();
二、Callable的使用場(chǎng)景
因?yàn)镃allable的call方法提供返回值,所以當(dāng)你需要知道任務(wù)執(zhí)行的結(jié)果時(shí),Callable是個(gè)不錯(cuò)的選擇。Callable的實(shí)現(xiàn)很簡(jiǎn)單。
如下兩個(gè)Callable任務(wù)分別返回false和0到520整數(shù)之和。
class BooleanCallableTask implements Callable<Boolean> { @Override public Boolean call() throws Exception { return false; } }
class IntegerCallableTask implements Callable<Integer> { @Override public Integer call() throws Exception { int sum = 0; for (int i = 0; i < 520; i++) { sum += i; } return sum; } }
Callable任務(wù)通過線程池的submit方法提交。且submit方法返回Future對(duì)象,通過Future的get方法可以獲得具體的計(jì)算結(jié)果。而且get是個(gè)阻塞的方法,如果任務(wù)未執(zhí)行完,則一直等待。
ExecutorService executor = Executors.newCachedThreadPool(); IntegerCallableTask integerCallableTask = new IntegerCallableTask(); Future<Integer> future = executor.submit(integerCallableTask); executor.shutdown(); try { System.out.println(future.get()); } catch (InterruptedException e) { e.printStackTrace(); } catch (ExecutionException e) { e.printStackTrace(); }
三、關(guān)于Future和FutureTask
對(duì)于Calleble來說,F(xiàn)uture和FutureTask均可以用來獲取任務(wù)執(zhí)行結(jié)果,不過Future是個(gè)接口,F(xiàn)utureTask是Future的具體實(shí)現(xiàn),而且FutureTask還間接實(shí)現(xiàn)了Runnable接口,也就是說FutureTask可以作為Runnable任務(wù)提交給線程池。
以下是個(gè)具體的實(shí)例演示FutureTask各種的使用方式。
static class Task implements Callable<Integer> { @Override public Integer call() throws Exception { System.out.println("子線程在進(jìn)行計(jì)算"); Thread.sleep(1000); int sum = 0; for (int i = 0; i < 10000; i++) sum += i; return sum; } } public static void main(String[] args) throws InterruptedException { ExecutorService executor = Executors.newCachedThreadPool(); //使用FutureTask Callable<Integer> task = new Task(); FutureTask<Integer> futureTask = new FutureTask<Integer>(task); executor.submit(futureTask); //使用Future // Callable<Integer> call = new Task(); // Future<Integer> future = executor.submit(call); executor.shutdown(); System.out.println("主線程在執(zhí)行任務(wù)"); Thread.sleep(2000); try { System.out.println("task運(yùn)行結(jié)果" + futureTask.get()); //future.get() } catch (InterruptedException e) { e.printStackTrace(); } catch (ExecutionException e) { e.printStackTrace(); } System.out.println("所有任務(wù)執(zhí)行完畢"); }
這個(gè)例子中使用Future和FutureTask都是一樣的,都能獲得相同的計(jì)算結(jié)果。
到此這篇關(guān)于Java中Runnable和Callable的區(qū)別和聯(lián)系的文章就介紹到這了,更多相關(guān)Java Runnable和Callable的區(qū)別內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家!
相關(guān)文章
Spring Boot集成ElasticSearch實(shí)現(xiàn)搜索引擎的示例
這篇文章主要介紹了Spring Boot集成ElasticSearch實(shí)現(xiàn)搜索引擎的示例,小編覺得挺不錯(cuò)的,現(xiàn)在分享給大家,也給大家做個(gè)參考。一起跟隨小編過來看看吧2017-11-11springmvc后臺(tái)基于@ModelAttribute獲取表單提交的數(shù)據(jù)
這篇文章主要介紹了springmvc后臺(tái)基于@ModelAttribute獲取表單提交的數(shù)據(jù),文中通過示例代碼介紹的非常詳細(xì),對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友可以參考下2019-10-10幾個(gè)好用Maven鏡像倉(cāng)庫(kù)地址(小結(jié))
這篇文章主要介紹了幾個(gè)好用Maven鏡像倉(cāng)庫(kù)地址(小結(jié)),文中通過示例代碼介紹的非常詳細(xì),對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧2020-09-09idea中g(shù)it如何刪除commit提交的log信息
這篇文章主要介紹了idea中g(shù)it如何刪除commit提交的log信息問題,具有很好的參考價(jià)值,希望對(duì)大家有所幫助。如有錯(cuò)誤或未考慮完全的地方,望不吝賜教2023-07-07java.io.EOFException產(chǎn)生原因及解決方法(附代碼)
java.io.EOFException表示在讀取數(shù)據(jù)時(shí)突然遇到了文件或流的末尾,也就是說客戶端或服務(wù)器已經(jīng)關(guān)閉了連接,但是你還在嘗試讀取數(shù)據(jù),這篇文章主要給大家介紹了關(guān)于java.io.EOFException產(chǎn)生原因及解決的相關(guān)資料,需要的朋友可以參考下2023-09-09