【併發那些事】建立線程的三種方式

時間 2020-01-06

標籤併發那些事建立線程三種方式简体版

原文原文鏈接

建立線程能夠說是併發知識中最基礎的操做了，JDK 提供的建立線程的方式，若是不包括經過線程池的話，目前有三種形式，它們分別是經過繼承 Thread 類，經過實現 Runable 接口，經過 FutureTask。以下圖所示java

下面整理了一下 3 種方法的具體使用與異同。多線程

建立線程的 3 種方法

1. 繼承 Thread

建立一個類繼承 Thread 並覆蓋 run 方法

class MyThread extends Thread {
    @Override
    public void run() {
        String threadName = getName();
        for (int i = 0; i &lt; 20; i++) {
            System.out.println("線程[" + threadName + "]運行開始,i = " + i + " time = " + new Date());
        }
    }
}

建立並啓動線程

MyThread myThread1 = new MyThread();
        MyThread myThread2 = new MyThread();

        myThread1.start();
        myThread2.start();

        String threadName = Thread.currentThread().getName();
        for (int i = 0; i &lt; 20; i++) {
            System.out.println("線程[" + threadName + "]運行開始,i = " + i + " time = " + new Date());
        }

總體流程以下：併發

這裏步驟比較簡單和清晰異步

建立一個類，這類要繼承 Thread
覆蓋 Thread 的 run 方法，並在此方法中實現你的多線程任務
建立這個類的實例
調用它的 start() 方法（這裏要注意，新手容易直接調用 run 方法，那樣只是普通調用，而很少線程調用）

2. 實現 Runable

建立一個類實現 Runable 接口，並覆蓋 run 方法

class MyRunable implements Runnable {
    
    @Override
    public void run() {
        String threadName = Thread.currentThread().getName();
        for (int i = 0; i &lt; 20; i++) {
            System.out.println("線程[" + threadName + "]運行開始,i = " + i + " time = " + new Date());
        }
    }
}

建立類的實現，並將它傳給 Thread 的構造函數來建立 Thread

MyRunable myRunable = new MyRunable();

new Thread(myRunable).start();
new Thread(myRunable).start();

String threadName = Thread.currentThread().getName();
for (int i = 0; i &lt; 20; i++) {
    System.out.println("線程[" + threadName + "]運行開始,i = " + i + " time = " + new Date());
}

總體流程以下：ide

具體步驟以下：函數

建立一個實現了 Runable 接口的類
覆蓋 run 方法，並在此方法中實現你的多線程任務
建立 Runable 接口實現類的實例
經過把上步獲得的 Runable 接口實現類的實例，傳給 Thread 的有參構造函數來建立 Thread 的實例
調用上步得來的 Thread 實例的 start() 方法（這裏要注意，新手容易直接調用 run 方法，那樣只是普通調用，而很少線程調用）

3. 經過 FutureTask

建立一個實現了 Callable<t> 接口的類，並實現call 方法 (T 表明你想要的返回值類型)

class MyCallerTask implements Callable<string> {
    
    @Override
    public String call() throws Exception {
        System.out.println("執行任務開始");
        Thread.sleep(3000);
        System.out.println("執行任務結束");
        return "hello";
    }
}

建立並啓動線程

// 建立異步任務
        FutureTask<string> futureTask = new FutureTask&lt;&gt;(new MyCallerTask());
        // 啓動線程
        new Thread(futureTask).start();
        System.out.println("其它操做");
        try {
            // 等待任務執行完，並得到任務執行完的結果
            String result = futureTask.get();
            System.out.println(result);
        } catch (InterruptedException e) {
            e.printStackTrace();
        } catch (ExecutionException e) {
            e.printStackTrace();
        }

總體流程以下：線程

具體步驟以下：3d