Java中Thread.interrupt源码分析

KINGYT

发布于 2023-03-15 13:52:32

4180

发布于 2023-03-15 13:52:32

文章被收录于专栏：Linux内核及编程语言底层相关技术研究Linux内核及编程语言底层相关技术研究

本文将从源码角度分析Thread.interrupt的实现机制。OpenJDK版本

➜ jdk hg id 76072a077ee1+ jdk-11+28

首先看下Thread.interrupt方法

Java类 java.lang.Thread

public void interrupt() {
    if (this != Thread.currentThread()) {
        checkAccess();


        // thread may be blocked in an I/O operation
        synchronized (blockerLock) {
            Interruptible b = blocker;
            if (b != null) {
                interrupt0();  // set interrupt status
                b.interrupt(this);
                return;
            }
        }
    }


    // set interrupt status
    interrupt0();
}
...
private native void interrupt0();

该方法主要做了两件事，首先是调用interrupt0，转向JVM做进一步的中断处理，其次是调用blocker.interrupt方法，中断blocker的当前操作，比如堵塞的io读写等。

我们这里主要看下interrupt0方法。该方法是native方法，看下对应的JVM内部的代码

文件 src/hotspot/share/prims/jvm.cpp

JVM_ENTRY(void, JVM_Interrupt(JNIEnv* env, jobject jthread))
  ...
  if (is_alive) {
    // jthread refers to a live JavaThread.
    Thread::interrupt(receiver);
  }
JVM_END

该方法最终调用了Thread::interrupt方法，看下这个方法

文件 src/hotspot/share/runtime/thread.cpp

void Thread::interrupt(Thread* thread) {
  ...
  os::interrupt(thread);
}

该方法调用了os::interrupt方法，继续看下这个

文件 src/hotspot/os/posix/os_posix.cpp

void os::interrupt(Thread* thread) {
  ...
  OSThread* osthread = thread->osthread();


  if (!osthread->interrupted()) {
    osthread->set_interrupted(true);
    ...
    ParkEvent * const slp = thread->_SleepEvent ;
    if (slp != NULL) slp->unpark() ;
  }


  // For JSR166. Unpark even if interrupt status already was set
  if (thread->is_Java_thread())
    ((JavaThread*)thread)->parker()->unpark();


  ParkEvent * ev = thread->_ParkEvent ;
  if (ev != NULL) ev->unpark() ;
}

这个方法就是最终的interrupt实现，它会首先设置线程的interrupted状态为true，然后分别调用各种ParkEvent或Parker的unpark方法，使其从阻塞状态返回。

比如，上面的_SleepEvent就是对应Thread.sleep方法，((JavaThread*)thread)->parker()就是对应LockSupport.park方法，_ParkEvent就是对应synchronized同步块及Object.wait方法。

有关ParkEvent或Parker的unpark方法是如何实现的，请看其他文章：

Java中LockSupport.park/unpark源码分析

本文参与腾讯云自媒体分享计划，分享自微信公众号。

原始发表：2019-01-23，如有侵权请联系 cloudcommunity@tencent.com 删除

java