彻底搞懂Java中的Runnable和Thread

发布时间 2023-08-01 18:59:14作者: nuccch

写在前面

今天在阅读ThreadPoolExecutor源码的时候觉得有些地方理解起来似是而非,很别扭!最后才猛然发现,原来是我自己的问题:没有真正理解Runnable和Thread的含义!
我之前对于RunnableThread理解的误区在于:“Runnble和Thread是实现多线程的两种方式,在Java中要实现多线程运行要么实现Runnable接口,要么继承Thread类”。咋一看对于这样的描述似乎也没毛病,但是它没有真正阐述清楚诸如“如何在Java中实现一个线程运行”,“Runnable与Thread的区别是什么”这样的问题。而且我看网上很多中文博客对于类似Runnable与Thread的区别这样的讨论也都大同小异,人云亦云,还是没有真正解答我心中的疑惑。

理解Java中的线程

文本中所说的“线程”都是指操作系统中的线程,如果希望任务能够异步执行,可以通过启动一个线程来实现。
Java是面向对象的编程语言,在Java中通过Thread类来实现对操作系统线程的抽象。
具体来说,在Java中一个操作系统线程与一个Thread对象关联,通过调用Thread对象的start()方法来启动一个操作系统线程执行。

关于Java中Thread类的具体说明详见Thread Objects

至此明确了一个认识:在Java中使用Thread来抽象操作系统中的线程,通过调用Thread对象的start()方法启动一个操作系统线程运行。

在Java中使用线程

上一节已经明确了在Java中通过Thread对象来操作线程,那么具体是怎么实现的呢?

如上图,在调用Thread.start()方法之后,会触发JVM本地方法的调用,随后创建一个新的操作系统线程环境执行Thread.run(),而有意思的是在Thread.run()中最终调用的的Runnable.run(),也就是说:通过Thread.start()启动的线程最终执行的是Runnable.run()

可以看到ThreadRunnable发生了关联,那么Runnable到底是什么呢?它们是如何产生关联的呢?
首先,Runnable是JDK中的一个接口。

public interface Runnable {
    public abstract void run();
}

其次,官方Runnble的解释如下:

The Runnable interface should be implemented by any class whose instances are intended to be executed by a thread. The class must define a method of no arguments called run.

直白的翻译:Runnable接口可以被任意打算在线程中执行的类实现,而且实现类必须实现接口中的无参方法run()
换句话说:Runnable是一个任务接口,它的run()方法用于实现在线程中真正的执行逻辑。
更进一步说:如果要在线程中异步执行一些业务操作,可以定义一个实现Runnable接口的类,然后将该Runnable对象传递给Thread对象。
因为Thread的源码实现就是直接调用了Runnable.run(),如下:

@Override
public void run() {
    // target是一个Runnable对象
    if (target != null) {
        target.run();
    }
}

再次,ThreadRunnable是如何发生关联的?通过阅读JDK源码可以知道,在Thread中保持了一个Runnable对象的引用。

public class Thread implements Runnable {
    /* What will be run. */
    private Runnable target;
}

而且,这个Runnable对象只能通过Thread的构造方法注入。

public Thread(Runnable target) {}
public Thread(Runnable target, AccessControlContext acc) {}
public Thread(ThreadGroup group, Runnable target) {}
public Thread(Runnable target, String name) {}
public Thread(ThreadGroup group, Runnable target, String name) {}
public Thread(ThreadGroup group, Runnable target, String name, long stackSize) {}

至此可以得出结论:在Java中要使用线程异步执行任务,必须结合ThreadRunnable来实现。具体来说:使用Runnable定义业务操作,使用Thread启动线程并执行Runnable
为什么说Thread必须要结合Runnable呢?没有Runnable可不可以呢?
Thread的源码实现来看,如果没有Runnable,那么通过Thread仅仅是启动了一个线程,但是在这个线程中什么也不做,这有什么意义呢?

// 实例化Thread对象
Thread thread = new Thread();
// 通过thread对象启动一个线程
// 但是没有给thread对象传递Runnable任务,所以这个线程启动之后并没有做任何有价值的事情就结束了
thread.start();

// Thread.run()
@Override
public void run() {
    // 如果没有注入Runnable对象,什么事情也不做直接返回
    if (target != null) {
        target.run();
    }
}

实际上,从JDK官方文档可知,有两种使用Thread对象的基本策略:
1.直接控制Thread对象创建和管理,每次需要开始一个异步任务的时候就实例化一个Thread对象,并调用其start()方法。

// 实例化一个Thread对象表示线程
Thread thread = new Thread();
// 调用Thread对象的start()方法启动线程
thread.start();

2.将线程管理(包括实例化Thread对象和调用start()方法启动操作系统线程)交给Executor框架。

注意:Executor框架提供的接口方法中并没有看到任何Thread对象的身影,而是一个Runnble对象。

public interface Executor {
    void execute(Runnable command);
}

实际上,这个要看具体的Executor接口实现类。
ThreadPoolExecutor为例,它在execute()方法的具体实现中将RunnableThread关联了起来,具体来说是在通过ThreadPoolExecutor.Worker进行关联的。ThreadPoolExecutor.Worker是一个内部类,它用于封装一个线程Thread对象和一个任务Runnable对象,从它的构造方法就能非常清晰地看到。

// 如下是JDK中ThreadPoolExecutor.Worker类的定义
private final class Worker extends AbstractQueuedSynchronizer implements Runnable {
    /** Thread this worker is running in.  Null if factory fails. */
    final Thread thread;

    /** Initial task to run.  Possibly null. */
    Runnable firstTask;

    Worker(Runnable firstTask) {
        setState(-1); // inhibit interrupts until runWorker
        this.firstTask = firstTask;
        this.thread = getThreadFactory().newThread(this);
    }
}

那么,ThreadPoolExecutor.Worker中的Thread是如何执行通过参数传递的Runnable对象呢?这个要从ThreadPoolExecutor的执行序列图来解答。

如上是调用ThreadPoolExecutor.execute()的执行序列图,在这个过程中最终也是通过Thread调用了传递进来的Rannable对象。
其实ThreadPoolExecutor除了实现Executor.execute()方法,还实现了ExecutorService.submit()方法,在submit()方法中允许执行一个有返回值的Callable任务。关于ThreadPoolExecutor的更多使用细则暂且不再论述,这里主要验证的是在Executor框架中调用线程时最终也是执行Runnable.run()

最后总结

关于Java中线程做如下总结:
1.使用Thread类作为线程的抽象,通过调用Thread.start()启动一个线程。
2.在线程中要执行的业务逻辑通过Runnable定义,具体来说是在Runnable.run()中定义。

一点延申思考

虽然说通过Thread.start()启动的线程最终执行的业务逻辑是在Runnable.run()中定义的,但是它们之间属于协作关系,可以说各自分工明确:Thread对象负责启动线程,Runnable负责定义业务操作。为什么Thread一定实现Runnable接口呢?Thread如果不实现Runnable接口是不是也可以呢?而且很可能正是因为Thread实现了Runnable这个缘故导致很多人对于ThreadRunnable的认识模棱两可。

再次回顾Java中线程的执行流程:Thread.start() -> Thread.start0()执行JVM本地方法 -> Thread.run() -> Runnable.run()
假设Thread类不实现Runnable接口,那么就需要在Thread类中自定义一个run()方法,那这样是否可行呢?坦白讲没什么不可以。
那什么JDK的实现中一定要让Thread类去实现Runnable接口呢?难道仅仅是为了获得一个run()方法吗?带着这个疑惑进行了相关资料的检索,其中一个原因值得参考:为了JVM的向后兼容性

【参考】
Difference between Runnable and Thread in Java
Why does the Thread Class implement Runnable interface
Why does Thread Class implements Runnable Interface [duplicate]
多线程(一) | 聊聊Thread和Runnable