【并发那些事】创建线程的三种方式

KIWI

发布于 2020-04-08 11:48:21

3370

发布于 2020-04-08 11:48:21

文章被收录于专栏：KIWI的碎碎念

创建线程可以说是并发知识中最基础的操作了，JDK 提供的创建线程的方式，如果不包括通过线程池的话，目前有三种形式，它们分别是通过继承 Thread 类，通过实现 Runable 接口，通过 FutureTask。如下图所示

下面整理了一下 3 种方法的具体使用与异同。

创建线程的 3 种方法

1. 继承 Thread

创建一个类继承 Thread 并覆盖 run 方法

class MyThread extends Thread {

    @Override
    public void run() {
        String threadName = getName();
        for (int i = 0; i < 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 < 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 < 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 < 20; i++) {
    System.out.println("线程[" + threadName + "]运行开始,i = " + i + " time = " + new Date());
}

整体流程如下：

具体步骤如下：

创建一个实现了 Runable 接口的类
覆盖 run 方法，并在此方法中实现你的多线程任务
创建 Runable 接口实现类的实例
通过把上步得到的 Runable 接口实现类的实例，传给 Thread 的有参构造函数来创建 Thread 的实例
调用上步得来的 Thread 实例的 start() 方法（这里要注意，新手容易直接调用 run 方法，那样只是普通调用，而不多线程调用）

3. 通过 FutureTask

创建一个实现了 Callable 接口的类，并实现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<>(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();
        }

整体流程如下：