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("线程中断了，程序到这里了");  }}

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