中文字幕av专区_日韩电影在线播放_精品国产精品久久一区免费式_av在线免费观看网站

溫馨提示×

溫馨提示×

您好,登錄后才能下訂單哦!

密碼登錄×
登錄注冊×
其他方式登錄
點擊 登錄注冊 即表示同意《億速云用戶服務條款》

Java多線程中創建線程的方法有哪些

發布時間:2021-06-07 13:07:22 來源:億速云 閱讀:180 作者:小新 欄目:編程語言

這篇文章主要介紹Java多線程中創建線程的方法有哪些,文中介紹的非常詳細,具有一定的參考價值,感興趣的小伙伴們一定要看完!

1.實現Runnable接口,重載run(),無返回值

package thread;
 
public class ThreadRunnable implements Runnable {
  public void run() {
    for (int i = 0; i < 10; i++) {
      System.out.println(Thread.currentThread().getName() + ":" + i);
    }
  }
}
 
 
package thread;
 
public class ThreadMain {
  public static void main(String[] args) throws Exception {
    ThreadRunnable threadRunnable1 = new ThreadRunnable();
    ThreadRunnable threadRunnable2 = new ThreadRunnable();
    ThreadRunnable threadRunnable3 = new ThreadRunnable();
    ThreadRunnable threadRunnable4 = new ThreadRunnable();
    Thread thread1 = new Thread(threadRunnable1);
    Thread thread2 = new Thread(threadRunnable2);
    Thread thread3 = new Thread(threadRunnable3);
    Thread thread4 = new Thread(threadRunnable4);
    thread1.start();
    thread2.start();
    thread3.start();
    thread4.start();
  }
}

2.繼承Thread類,復寫run()

使用時通過調用Thread的start()(該方法是native),再調用創建線程的run(),不同線程的run方法里面的代碼交替執行。

不足:由于java為單繼承,若使用線程類已經有個父類,則不能使用該方式創建線程。

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

3.實現Callable接口,通過FutureTask/Future來創建有返回值的Thread線程,通過Executor執行

補充:與實現Runnable接口類似,都是實現接口,不同的是該方式有返回值,可以獲得異步執行的結果。

延伸:FutureTask是類,Future是接口。

package thread;
 
import java.util.concurrent.*;
 
public class ThreadCallable {
  public static void main(String[] args) throws Exception {
    FutureTask<Integer> futureTask = new FutureTask<Integer>(new Callable<Integer>() {
      public Integer call() throws Exception {
        for (int i = 0; i < 10; i++) {
          System.out.println(Thread.currentThread().getName() + ":" + i);
        }
        return 1;
      }
    });
    Executor executor = Executors.newFixedThreadPool(1);
    ((ExecutorService) executor).submit(futureTask);
 
    //獲得線程執行狀態
    System.out.println(Thread.currentThread().getName() + ":" + futureTask.get());
  }
}

4.使用Executors創建ExecutorService,入參Callable或Future

補充:適用于線程池和并發

package thread;
 
import java.util.concurrent.Callable;
import java.util.concurrent.Executors;
import java.util.concurrent.ThreadFactory;
 
import static java.lang.Thread.sleep;
 
public class ThreadExecutors {
  private final String threadName;
 
  public ThreadExecutors(String threadName) {
    this.threadName = threadName;
  }
 
  private ThreadFactory createThread() {
    ThreadFactory tf = new ThreadFactory() {
      public Thread newThread(Runnable r) {
        Thread thread = new Thread();
        thread.setName(threadName);
        thread.setDaemon(true);
        try {
          sleep(1000);
        }
        catch (InterruptedException e) {
          e.printStackTrace();
        }
        return thread;
      }
    };
    return tf;
  }
 
  public Object runCallable(Callable callable) {
    return Executors.newSingleThreadExecutor(createThread()).submit(callable);
  }
 
  public Object runFunture(Runnable runnable) {
    return Executors.newSingleThreadExecutor(createThread()).submit(runnable);
  }
}
 
 
 
package thread;
 
import java.util.concurrent.*;
 
public class ThreadMain {
  public static void main(String[] args) throws Exception {
    ThreadExecutors threadExecutors = new ThreadExecutors("callableThread");
    threadExecutors.runCallable(new Callable() {
      public String call() throws Exception {
        return "success";
      }
    });
 
    threadExecutors.runFunture(new Runnable() {
      public void run() {
        System.out.println("execute runnable thread.");
      }
    });
  }
}

5 Runnable接口和Callable接口區別

  1. 1)兩個接口需要實現的方法名不一樣,Runnable需要實現的方法為run(),Callable需要實現的方法為call()。

  2. 2)實現的方法返回值不一樣,Runnable任務執行后無返回值,Callable任務執行后可以得到異步計算的結果。

  3. 3)拋出異常不一樣,Runnable不可以拋出異常,Callable可以拋出異常。

6 Callable返回值意義在哪兒,不要返回值可以嗎,什么時候需要用到返回值?

首先Callable是線程異步執行的結果狀態,如果有兩個線程A和B,B中的某個業務邏輯中需要確定A結束后才能進行,那么就需要獲得線程A的執行結果。

設計背景:一個任務需要進行一系列操作,比如拷貝大量的基礎數據,以及解析數據,并入庫,由于數量大,整個過程需要持續十秒左右,用戶體驗差,需要降低到2~5s。

設計思路:經過分解過程,將拷貝數據分為一個過程,同時涵蓋部分解析數據功能,剩下解析數據劃為一個過程,兩個過程異步執行,其中最后一個任務狀態入庫時需要將所有業務操作都執行完成后更新,此時就需要用到線程中的返回值。

以上是“Java多線程中創建線程的方法有哪些”這篇文章的所有內容,感謝各位的閱讀!希望分享的內容對大家有幫助,更多相關知識,歡迎關注億速云行業資訊頻道!

向AI問一下細節

免責聲明:本站發布的內容(圖片、視頻和文字)以原創、轉載和分享為主,文章觀點不代表本網站立場,如果涉及侵權請聯系站長郵箱:is@yisu.com進行舉報,并提供相關證據,一經查實,將立刻刪除涉嫌侵權內容。

AI

霍山县| 普格县| 遂昌县| 漠河县| 齐齐哈尔市| 丹寨县| 蓬莱市| 阳曲县| 加查县| 泸溪县| 齐齐哈尔市| 昌吉市| 简阳市| 高台县| 唐海县| 天全县| 姚安县| 房山区| 苏尼特左旗| 淳化县| 尉犁县| 静乐县| 喀喇沁旗| 通州区| 阜新市| 盐城市| 沛县| 阳曲县| 玛曲县| 美姑县| 昌乐县| 邵武市| 兴城市| 通江县| 静乐县| 桑植县| 杭州市| 得荣县| 佳木斯市| 九江县| 会东县|