Java多线程 中断机制及实例详解

  public void interrupt() {
    if (this != Thread.currentThread())
      checkAccess();
    synchronized (blockerLock) {
      Interruptible b = blocker;
      if (b != null) {
        interrupt0();      // Just to set the interrupt flag
        b.interrupt(this);
        return;
      }
    }
    interrupt0();
  }

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

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

void os::interrupt(Thread* thread) {
 ...
 OSThread* osthread = thread->osthread();
 if (!osthread->interrupted()) {
  //设置中断标识位
  osthread->set_interrupted(true);
  ...
 }
  ...
}

public boolean isInterrupted() {
    return isInterrupted(false);
  }

bool os::is_interrupted(Thread* thread, bool clear_interrupted) {
 debug_only(Thread::check_for_dangling_thread_pointer(thread);)
 OSThread* osthread = thread->osthread();
 // 查看是否被中断
 bool interrupted = osthread->interrupted();
 // 清除标识位后再设置false
 if (interrupted && clear_interrupted) {
  osthread->set_interrupted(false);
 }
 return interrupted;
}

  public static boolean interrupted() {
    return currentThread().isInterrupted(true);
  }

public class MyThread45 {
  public static void main(String[] args) throws Exception
  {
    Runnable runnable = new Runnable()
    {
      public void run()
      {
        while (true)
        {
          if (Thread.currentThread().isInterrupted())
          {
            System.out.println("线程被中断了");
            return ;
          }
          else
          {
            System.out.println("线程没有被中断");
          }
        }
      }
    };
    Thread t = new Thread(runnable);
    t.start();
    Thread.sleep(500);
    t.interrupt();
    System.out.println("线程中断了，程序到这里了");
  }
}

······
线程没有被中断
线程没有被中断
线程没有被中断
线程被中断了
线程中断了，程序到这里了