本文實(shí)例講述了Java使用Callable和Future創(chuàng)建線程操作。分享給大家供大家參考，具體如下：

一 點(diǎn)睛

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

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

創(chuàng)建并啟動(dòng)線程的步驟如下：

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

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

3 使用FutureTask對象作為Thread對象的target創(chuàng)建并啟動(dòng)新線程。

4 調(diào)用FutureTask對象的get()方法來獲得子線程執(zhí)行結(jié)束后的返回值。

二 代碼

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

三 運(yùn)行

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

四 說明

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

更多java相關(guān)內(nèi)容感興趣的讀者可查看本站專題：《Java進(jìn)程與線程操作技巧總結(jié)》、《Java數(shù)據(jù)結(jié)構(gòu)與算法教程》、《Java操作DOM節(jié)點(diǎn)技巧總結(jié)》、《Java文件與目錄操作技巧匯總》和《Java緩存操作技巧匯總》

希望本文所述對大家java程序設(shè)計(jì)有所幫助。

最新評論