zoukankan      html  css  js  c++  java
  • interrupt和interrupted和isInterrupted的区别

    原创转载请注明出处:https://www.cnblogs.com/agilestyle/p/11413917.html

    interrupt

    Code Demo

     1 package org.fool.thread;
     2 
     3 public class InterruptTest1 {
     4     public static void main(String[] args) {
     5         Thread thread = new Thread(new Runnable() {
     6             @Override
     7             public void run() {
     8                 for (int i = 0; i < 100000; i++) {
     9                     System.out.println(Thread.currentThread().getName() + " i = " + i);
    10                 }
    11             }
    12         });
    13 
    14         thread.start();
    15 
    16         thread.interrupt();
    17     }
    18

    Note:

    从运行结果来看,调用interrupt方法并没有停止线程

    interrupted

    Code Demo

     1 package org.fool.thread;
     2 
     3 public class InterruptTest2 {
     4     public static void main(String[] args) {
     5         Thread thread = new Thread(() -> {
     6             for (int i = 0; i < 10; i++) {
     7                 System.out.println(Thread.currentThread().getName() + " i = " + i);
     8 
     9                 if (i == 5) {
    10                     Thread.currentThread().interrupt();
    11 
    12                     System.out.println("interrupted 1: " + Thread.interrupted());
    13 
    14                     System.out.println("interrupted 2: " + Thread.interrupted());
    15                 }
    16             }
    17         });
    18 
    19         thread.start();
    20 
    21     }
    22 }

    Console Output

    Note:

    控制台第一次打印的结果是true,第二次为false;Java Doc中给出的解释是:测试当前线程是否已经中断,线程的中断状态由该方法清除。即如果连续两次调用该方法,则第二次调用将返回false(在第一次调用已清除flag后以及第二次调用检查中断状态之前,当前线程再次中断的情况除外)

    所以,interrupted()方法具有清除状态flag的功能 

    isInterrupted

    Code Demo

     1 package org.fool.thread;
     2 
     3 public class InterruptTest3 {
     4     public static void main(String[] args) {
     5         Thread thread = new Thread(() -> {
     6             for (int i = 0; i < 10; i++) {
     7                 System.out.println(Thread.currentThread().getName() + " i = " + i);
     8             }
     9         });
    10 
    11         thread.start();
    12 
    13         // main thread interrupt
    14         Thread.currentThread().interrupt();
    15 
    16         System.out.println(thread.getName() + ":" + thread.isInterrupted());
    17         System.out.println(thread.getName() + ":" + thread.isInterrupted());
    18         System.out.println(Thread.currentThread().getName() + ":" + Thread.currentThread().isInterrupted());
    19         System.out.println(Thread.currentThread().getName() + ":" + Thread.currentThread().isInterrupted());
    20 
    21         // thread interrupt
    22         thread.interrupt();
    23 
    24         System.out.println(thread.getName() + ":" + thread.isInterrupted());
    25         System.out.println(thread.getName() + ":" + thread.isInterrupted());
    26     }
    27 }

    Console Output

    Summary

    调用interrupt()方法仅仅是在当前线程中打了一个停止的标记,并不是真正的停止线程

    interrupted()测试当前线程是否已经是中断状态,执行后具有清除中断状态flag的功能

    isInterrupted()测试线程Thread对象是否已经是中断状态,但不清除中断状态flag 

  • 相关阅读:
    Redis源码解析(十五)--- aof-append only file解析
    Redis源码解析(十五)--- aof-append only file解析
    Redis源码解析(十五)--- aof-append only file解析
    Storm的起源概况
    Storm的起源概况
    Storm的起源概况
    Storm的基本知识
    Storm的基本知识
    Storm的基本知识
    Redis源码解析(十六)--- config配置文件
  • 原文地址:https://www.cnblogs.com/agilestyle/p/11413917.html
Copyright © 2011-2022 走看看