Java線程的三種創建方式

1、Thread

繼承Thread類,並重寫run方法

class ThreadDemo1 extends Thread {

  @Override

  public void run() {

    log.info("{}", Thread.currentThread().getName());

  }

}

線程啟動方式:

ThreadDemo1 t1 = new ThreadDemo1();

t1.setName("t1");

t1.start();

簡便寫法:

Thread t1 = new Thread() {

    @Override

    public void run() {

        log.info("{}", Thread.currentThread().getName());

    }

};

t1.setName("t1");

t1.start();

2、Runnable和Thread

Thread類的構造函數支持傳入Runnable的實現類

public Thread(Runnable target) {

    init(null, target, "Thread-" + nextThreadNum(), 0);

}

Thread(Runnable target, AccessControlContext acc) {

    init(null, target, "Thread-" + nextThreadNum(), 0, acc, false);

}

Runnable是一個函數式接口(FunctionalInterface

@FunctionalInterface

public interface Runnable {

    // 沒有返回值

    public abstract void run();

}

因此需要創建類實現Runnable接口,重寫run方法

class ThreadDemo2 implements Runnable {

    @Override

    public void run() {

        log.info("{}", Thread.currentThread().getName());

    }

}

簡便寫法:

Thread t2 = new Thread(() -> log.info("{}", Thread.currentThread().getName()), "t2");

t2.start();

3、Runnable和Thread

CallableRunnable一樣,也是一個函數式接口,二者的區別非常明顯,Runnablerun方法沒有返回值,Callable中的run方法有返回值(可以通過泛型約束返回值類型)。因此在需要獲取線程執行的返回值時,可以使用Callable

@FunctionalInterface

public interface Callable<V> {

    // 帶返回值

    V call() throws Exception;

}

Thread的構造函數中,並沒有看到Callable,隻有Runnable

此時需要一個可以提交Callable給Thread的類,這類就是FutureTask;FutureTask實現類Runnable接口。

並且FutureTask提供瞭傳入Callable的構造函數

public FutureTask(Callable<V> callable) {

    if (callable == null)

        throw new NullPointerException();

    this.callable = callable;

    this.state = NEW;       // ensure visibility of callable

}

因此可以通過FutureTask傳入Callable實現,再將FutureTask傳給Thread即可

ThreadDemo3 implements Callable<Integer> {

    @Override

    public Integer call() throws Exception {

        log.info("{}", Thread.currentThread().getName());

        return 1998;

    }

}
// Callable 實現類

ThreadDemo3 callable = new ThreadDemo3();

// 通過Callable創建FutureTask

FutureTask<Integer> task = new FutureTask(callable);

// 通過FutureTask創建Thread

Thread t3 = new Thread(task, "t3");

t3.start();

簡便寫法:

Thread t3 = new Thread(new FutureTask<Integer>(() -> {

    log.info("{}", Thread.currentThread().getName());

    return 1998;

}), "t3");

t3.start();

4、三者對比

創建線程的方式有三種:

ThreadRunnable+ThreadCallable+FutureTask+Thread;這三者如何選擇呢?

  • 首先在實際的開發過程中,我們不會直接創建線程,因為頻繁創建和銷毀線程開銷比較大,此外不利於管理和釋放,因此項目中都是通過設計線程池來管理線程資源
  • ThreadRunnable+Thread相比,Runnable+Thread將線程的創建和任務模塊解耦瞭,代碼設計更加靈活,此外更加利於任務的提交,更方便和線程池結合使用
  • Callable+FutureTask+Thread適用於需要獲取線程返回結果的場景

5、註意項

文中多次使用thread.start();需要註意的是,調用線程的start()方法表示啟動線程,但是線程是否執行並不確定,這需要操作系統調度,線程分配到CPU執行時間片才能執行。多核CPU下多個線程同時啟動,線程之間交替執行,執行順序是不確定的。

到此這篇關於Java線程的三種創建方式的文章就介紹到這瞭,更多相關Java線程創建方式內容請搜索WalkonNet以前的文章或繼續瀏覽下面的相關文章希望大傢以後多多支持WalkonNet!

推薦閱讀: