您好,登錄后才能下訂單哦!
Java線程池在運行后的結果反查是怎樣的,針對這個問題,這篇文章詳細介紹了相對應的分析和解答,希望可以幫助更多想解決這個問題的小伙伴找到更簡單易行的方法。
Java線程池需要不斷的學習,在學習的時候我們就要注意不少的問題。下面我們就來看看具體的語言運作環境如何才能滿足Java線程池相關程序的運行。
無論是接收Runnable型參數,還是接收Callable型參數的submit()方法,都會返回一個Future(也是一個接口)類型的對象。該對象中包含了任務的執行情況以及結果。調用Future的boolean isDone()方法可以獲知任務是否執行完畢;調用Object get()方法可以獲得任務執行后的返回結果,如果此時任務還沒有執行完,get()方法會保持等待,直到相應的任務執行完畢后,才會將結果返回。
我們用下面的一個例子來演示Java5.0中Java線程池的使用:
Java代碼
import java.util.concurrent.*;
public class ExecutorTest {
public static void main(String[] args) throws
InterruptedException,ExecutionException {
ExecutorService es = Executors.newSingleThreadExecutor();
Future fr = es.submit(new RunnableTest());// 提交任務
Future fc = es.submit(new CallableTest());// 提交任務
// 取得返回值并輸出
System.out.println((String) fc.get());
// 檢查任務是否執行完畢
if (fr.isDone()) {
System.out.println("執行完畢-RunnableTest.run()");
} else {
System.out.println("未執行完-RunnableTest.run()");
}
// 檢查任務是否執行完畢
if (fc.isDone()) {
System.out.println("執行完畢-CallableTest.run()");
} else {
System.out.println("未執行完-CallableTest.run()");
}
// 停止線程池服務
es.shutdown();
}
}
class RunnableTest implements Runnable {
public void run() {
System.out.println("已經執行-RunnableTest.run()");
}
}
class CallableTest implements Callable {
public Object call() {
System.out.println("已經執行-CallableTest.call()");
return "返回值-CallableTest.call()";
}
}
import java.util.concurrent.*;
public class ExecutorTest {
public static void main(String[] args) throws
InterruptedException,ExecutionException {
ExecutorService es = Executors.newSingleThreadExecutor();
Future fr = es.submit(new RunnableTest());// 提交任務
Future fc = es.submit(new CallableTest());// 提交任務
// 取得返回值并輸出
System.out.println((String) fc.get());
// 檢查任務是否執行完畢
if (fr.isDone()) {
System.out.println("執行完畢-RunnableTest.run()");
} else {
System.out.println("未執行完-RunnableTest.run()");
}
// 檢查任務是否執行完畢
if (fc.isDone()) {
System.out.println("執行完畢-CallableTest.run()");
} else {
System.out.println("未執行完-CallableTest.run()");
}
// 停止線程池服務
es.shutdown();
}
}
class RunnableTest implements Runnable {
public void run() {
System.out.println("已經執行-RunnableTest.run()");
}
}
class CallableTest implements Callable {
public Object call() {
System.out.println("已經執行-CallableTest.call()");
return "返回值-CallableTest.call()";
}
}
運行結果:
已經執行-RunnableTest.run()
已經執行-CallableTest.call()
返回值-CallableTest.call()
執行完畢-RunnableTest.run()
執行完畢-CallableTest.run()
使用完Java線程池后,需要調用它的shutdown()方法停止服務,否則其中的所有線程都會保持運行,程序不會退出。
關于Java線程池在運行后的結果反查是怎樣的問題的解答就分享到這里了,希望以上內容可以對大家有一定的幫助,如果你還有很多疑惑沒有解開,可以關注億速云行業資訊頻道了解更多相關知識。
免責聲明:本站發布的內容(圖片、視頻和文字)以原創、轉載和分享為主,文章觀點不代表本網站立場,如果涉及侵權請聯系站長郵箱:is@yisu.com進行舉報,并提供相關證據,一經查實,將立刻刪除涉嫌侵權內容。