怎么在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的值：98
main 的循環變量i的值：99
有返回值的線程 的循環變量i的值：23
有返回值的線程 的循環變量i的值：24
有返回值的線程 的循環變量i的值：25
......
有返回值的線程 的循環變量i的值：94
有返回值的線程 的循環變量i的值：95
有返回值的線程 的循環變量i的值：96
有返回值的線程 的循環變量i的值：97
有返回值的線程 的循環變量i的值：98
有返回值的線程 的循環變量i的值：99
子線程的返回值：100

上述內容就是怎么在Java中利用Callable和Future創建線程，你們學到知識或技能了嗎？如果還想學到更多技能或者豐富自己的知識儲備，歡迎關注億速云行業資訊頻道。