App下載

Java線程之三種實(shí)現(xiàn)方式

猿友 2021-01-29 11:31:21 瀏覽數(shù) (2956)
反饋

繼承 Thread 類創(chuàng)建線程類

Thread 的實(shí)現(xiàn)步驟:

  1. 定義 Thread 的子類,重寫 run()方法,run()方法代表了線程要完成的任務(wù),run()方法稱為線程執(zhí)行體。
  2. 創(chuàng)建 Thread 子類的實(shí)例,子類對(duì)象就是線程。
  3. 調(diào)用線程對(duì)象的 start()方法來啟動(dòng)線程。

public class ThreadDemo extends Thread{
?
  public void run() {
      for(int i=0;i<10;i++) {
          System.out.println(currentThread().getName()+":" + i);
      }
  }
?
  public static void main(String args[]) {
      new ThreadDemo().start();
      new ThreadDemo().start();
  }
}

運(yùn)行結(jié)果:
   微信截圖_20210129101510

實(shí)現(xiàn) Runnable 接口創(chuàng)建線程類

Runnable的實(shí)現(xiàn)步驟:

  1. 定義 Runnable 接口實(shí)現(xiàn)類,重寫 run()方法,run() 方法代表了線程要完成的任務(wù),run()方法稱為線程執(zhí)行體。
  2. 創(chuàng)建 Runnable 實(shí)現(xiàn)類的實(shí)例,Runnable 本身就是 Thread 類的方法,所以創(chuàng)建線程還要實(shí)現(xiàn)一個(gè) Thread 類來包裝 Runnable 對(duì)象。
  3.  調(diào)用線程對(duì)象的 start() 方法來啟動(dòng)線程。

public class RunnableDemo implements Runnable{
?
  String threadName;
?
  public RunnableDemo(String threadName) {
      this.threadName = threadName;
  }
?
  @Override
  public void run() {
      for(int i=0;i<10;i++) {
          System.out.println(threadName+":" + i);
      }
  }
?
  public static void main(String args[]) {
      new Thread(new RunnableDemo("A")).start();
      new Thread(new RunnableDemo("B")).start();
  }
}

運(yùn)行結(jié)果:
   微信截圖_20210129101524

實(shí)現(xiàn) Callable 接口創(chuàng)建線程類

從 Java5 開始就提供了 Callable 接口,該接口是 Runnable 接口的增強(qiáng)版,Callable 接口提供一個(gè) call() 方法作為線程執(zhí)行體,call()方法可以有返回值,call() 方法可以聲明拋出異常。

  • ?boolean cancel(boolean may) ?試圖取消該 Future 里關(guān)聯(lián)的 Callable 任務(wù)。
  • ?V get() ?返回 Call 任務(wù)里 call() 方法的返回值。調(diào)用該方法會(huì)照成線程阻塞,必須等待子線程結(jié)束后才會(huì)得到返回值。
  • ?V get(long timeout,TimeUnit unit) ?返回 Call 任務(wù)里 call() 方法的返回值。該方法讓程序最多阻塞 timeout 和 unit 指定的時(shí)間,如果經(jīng)過指定的時(shí)間,如果經(jīng)過指定的時(shí)間依然沒有返回值,將會(huì)拋出 TimeoutException 異常。
  • ?boolean isCancelled() ?如果在 Callable 任務(wù)正常完成前被取消,則返回 true。
  • ?boolean isDone() ?如果 Callable 任務(wù)已完成,則返回 true。

Runnable的實(shí)現(xiàn)步驟:

  1. 創(chuàng)建 Callable 接口的實(shí)現(xiàn)類,并實(shí)現(xiàn) call() 方法,該 call() 方法作為線程的執(zhí)行體,call() 方法有返回值。
  2. 使用 FutrueTask 類包裝 Callable 對(duì)象。
  3. 使用 FutrueTask 對(duì)象作為Thread 對(duì)象的 target 創(chuàng)建并啟動(dòng)新線程。
  4. 啟用 FutrueTask 對(duì)象的 get() 方法來獲得子線程的返回值。

public class CallableDemo implements Callable<Integer> {
  public static void main(String args[]) {
      FutureTask<Integer> futureTask = new FutureTask<Integer>(new CallableDemo());
      new Thread(futureTask).start();
      try {
          System.out.println("子線程返回值:" + futureTask.get());
      } catch (InterruptedException e) {
          e.printStackTrace();
      } catch (ExecutionException e) {
          e.printStackTrace();
      }
      if (futureTask.isDone()) {
          System.out.println("線程結(jié)束");
      }
  }
?
  @Override
  public Integer call() throws Exception {
      System.out.println("線程開始");
      int ss = 0;
      for (int i = 0; i < 20; i++) {
          ss += i;
      }
      return ss;
  }
}

運(yùn)行結(jié)果:

微信截圖_20210129101546


0 人點(diǎn)贊