Java中怎么使用Callable和Future創建線程

今天就跟大家聊聊有關Java中怎么使用Callable和Future創建線程，可能很多人都不太了解，為了讓大家更加了解，小編給大家總結了以下內容，希望大家根據這篇文章可以有所收獲。

一 點睛

從Java 5開始，Java提供了Callable接口，該接口是Runnable接口的增強版，Callable接口提供了一個call()方法，可以看作是線程的執行體，但call()方法比run()方法更強大。

call()方法可以有返回值。  call()方法可以聲明拋出異常。

創建并啟動線程的步驟如下：

1 創建Callable接口的實現類，并實現call()方法，該call()方法將作為該線程的執行體，且該call()方法有返回值，再創建Callable的實例。從Java 8開始，可以直接使用Lamda表達式創建Callable對象。

2 使用FutureTask類來包裝Callable對象，該FutureTask對象封裝了該Callable對象的call()方法的返回值。

3 使用FutureTask對象作為Thread對象的target創建并啟動新線程。

4 調用FutureTask對象的get()方法來獲得子線程執行結束后的返回值。

二 代碼

public class ThirdThread{   public static void main(String[] args)   {      // 創建Callable對象      ThirdThread rt = new ThirdThread();      // 先使用Lambda表達式創建Callable<Integer>對象      // 使用FutureTask來包裝Callable對象      FutureTask<Integer> task = new FutureTask<Integer>((Callable<Integer>)() -> {        int i = 0;        for ( ; i < 100 ; i++ )        {           System.out.println(Thread.currentThread().getName()              + " 的循環變量i的值：" + i);        }        // call()方法可以有返回值        return i;      });      for (int i = 0 ; i < 100 ; i++)      {        System.out.println(Thread.currentThread().getName()           + " 的循環變量i的值：" + i);        if (i == 20)        {           // 實質還是以Callable對象來創建、并啟動線程           new Thread(task , "有返回值的線程").start();        }      }      try      {        // 獲取線程返回值        System.out.println("子線程的返回值：" + task.get());      }      catch (Exception ex)      {        ex.printStackTrace();      }   }}

三 運行

main 的循環變量i的值：98main 的循環變量i的值：99有返回值的線程 的循環變量i的值：23有返回值的線程 的循環變量i的值：24有返回值的線程 的循環變量i的值：25......有返回值的線程 的循環變量i的值：94有返回值的線程 的循環變量i的值：95有返回值的線程 的循環變量i的值：96有返回值的線程 的循環變量i的值：97有返回值的線程 的循環變量i的值：98有返回值的線程 的循環變量i的值：99子線程的返回值：100

四 說明

程序先使用使用Lamda表達式創建一個Callable對象，然后將該實例包裝成一個FutureTask對象。主線程中當循環變量i等于20時，程序啟動以FutrueTask對象為target的線程。程序最后調用FutrueTask對象的get()方法來返回call()方法的返回值——該方法將導致主線程被阻塞,直到call()方法結束并返回為止。

看完上述內容，你們對Java中怎么使用Callable和Future創建線程有進一步的了解嗎？如果還想了解更多知識或者相關內容，請關注億速云行業資訊頻道，感謝大家的支持。