Java thread.isInterrupted() 返回值不确定结果分析解决

目录
  • 一、代码
  • 二、分析结果
  • 三、解决方案

一、代码

先上代码（以下这段代码会有多种执行结果）

@Test
public void test_interrupted_thread() throws Exception {
    InterruptThread interruptThread = new InterruptThread();
    interruptThread.start();
    interruptThread.interrupt();
    System.out.println("interruptThread.isInterrupted()：" + interruptThread.isInterrupted());
}
public class InterruptThread extends Thread {
    @Override
    public void run() {
        for (int i=0; i< 3; i++) {
            System.out.println("i=" + (i + 1));
        }
        System.out.println("【InterruptThread】结束");
    }
}

执行结果1：
i=1
i=2
i=3
【Thread-0】【InterruptThread】结束
【main】interruptThread.isInterrupted()：false
执行结果2：
【main】interruptThread.isInterrupted()：true
i=1
i=2
i=3
【Thread-0】【InterruptThread】结束
执行结果3：
i=1
i=2
i=3
【Thread-0】【InterruptThread】结束
【main】interruptThread.isInterrupted()：true

二、分析结果

执行结果1：

Main线程调用了interruptThread.start();，interruptThread线程启动，执行了interruptThread线程内容，同时Main线程调用了interruptThread.interrupt();，设定了interruptThread线程中断标记为true，最后InterruptThread结束，清除中断标记，Main线程调用interruptThread.isInterrupted() 获取interruptThread线程中断标记为false。

执行结果2：

Main线程调用了interruptThread.start();，interruptThread线程启动，但是由于CPU随机调度，在执行了interruptThread线程内容前，先执行Main线程调用interruptThread.interrupt();，设定了interruptThread线程中断标记为true，且先调用interruptThread.isInterrupted()获取interruptThread线程中断标记为true并输出，最后在执行interruptThread线程内容。

执行结果3：

Main线程调用了interruptThread.start();，interruptThread线程启动，执行了interruptThread线程内容，同时Main线程调用了interruptThread.interrupt();，设定了interruptThread线程中断标记为true，最后InterruptThread结束，但是Main线程调用interruptThread.isInterrupted() 获取interruptThread线程中断标记为true。（与执行结果1执行顺序一致，但是最终结果不一致）

原因分析：

Main线程调用interruptThread.interrupt()后立即调用interruptThread.isInterrupted()，虽然interruptThread执行结束，但有可能在interruptThread线程还未完成清除打断标记就Main线程就查看打断标记，此时仍然为true。

三、解决方案

如果Main线程要得到稳定的false，即重置打断标记后的结果，有如下方案：

（1）需要Main线程在调用interruptThread.interrupt();，对Main线程sleep一会，给点时间，再通过调用interruptThread.isInterrupted()获取interruptThread线程的中断状态。

@Test
public void test_interrupted_thread() throws Exception {
    InterruptThread interruptThread = new InterruptThread();
    interruptThread.start();
    interruptThread.interrupt();
    Thread.sleep(100);
    System.out.println("【" + Thread.currentThread().getName() + "】" + "interruptThread.isInterrupted()：" + interruptThread.isInterrupted());
}

（2）也可以通过Main线程调用interruptThread.join()，让Main线程等到interruptThread执行直到中止后再调用interruptThread.isInterrupted()获取interruptThread线程的中断状态。

@Test
public void test_interrupted_thread() throws Exception {
    InterruptThread interruptThread = new InterruptThread();
    interruptThread.start();
    interruptThread.interrupt();
    interruptThread.join();
    System.out.println("【" + Thread.currentThread().getName() + "】" + "interruptThread.isInterrupted()：" + interruptThread.isInterrupted());
}

到此这篇关于Java thread.isInterrupted() 返回值不确定结果分析解决的文章就介绍到这了,更多相关Java thread.isInterrupted() 内容请搜索我们以前的文章或继续浏览下面的相关文章希望大家以后多多支持我们！

赞 (0)

相关推荐

  • Java线程池ThreadPoolExecutor源码深入分析

    1.线程池Executors的简单使用 1)创建一个线程的线程池. Executors.newSingleThreadExecutor(); //创建的源码 public static ExecutorService newSingleThreadExecutor() { return new FinalizableDelegatedExecutorService (new ThreadPoolExecutor(1, 1, 0L, TimeUnit.MILLISECONDS, new Linke

  • 深入理解Java并发编程之ThreadLocal

    深入理解Java并发编程之ThreadLocal

    目录 ThreadLocal简介 ThreadLocal源码解析 实现原理 ThreadLocalMap源码分析 InheritableThreadLocal 参考资料 ThreadLocal简介 变量值的共享可以使用public static的形式,所有线程都使用同一个变量,如果想实现每一个线程都有自己的共享变量该如何实现呢?JDK中的ThreadLocal类正是为了解决这样的问题. ThreadLocal类并不是用来解决多线程环境下的共享变量问题,而是用来提供线程内部的共享变量,在多线程环境

  • Java多线程ThreadPoolExecutor详解

    目录 1 newFixedThreadPool 2 newCachedThreadPool 3 newSingleThreadExecutor 4 提交任务 5 关闭线程池 前言: 根据ThreadPoolExecutor的构造方法,JDK提供了很多工厂方法来创建各种用途的线程池. 1 newFixedThreadPool public static ExecutorService newFixedThreadPool(int nThreads) { return new ThreadPoolE

  • Java Thread之Sleep()使用方法及总结

    目录 一.API简介 二.使用方法 三.示例 四.注意问题 一.API简介 Thread.sleep()是Thread类的一个静态方法,使当前线程休眠,进入阻塞状态(暂停执行),如果线程在睡眠状态被中断,将会抛出IterruptedException中断异常.. 主要方法如下: [a]sleep(long millis)  线程睡眠 millis 毫秒 [b]sleep(long millis, int nanos)  线程睡眠 millis 毫秒 + nanos 纳秒 Api文档: 二.使用方

  • Java Thread 类和Runnable 接口详解

    目录 一.Thread 类 1.操作线程名称的方法 2.获取当前正在执行的线程 一.Thread 类 了解如何使用Thread 类实现多线程之后,继续学习Thread 类实现多线程之后的相关功能及方法. 1.操作线程名称的方法 构造方法(实现 Runnable 接口时候使用) public Thread(Runnable target,String name); 创建线程时设置线程名称. 成员方法: public final void setName(String name): 设置线程的名称.

  • Java thread.isInterrupted() 返回值不确定结果分析解决

    目录 一.代码 二.分析结果 三.解决方案 一.代码 先上代码(以下这段代码会有多种执行结果) @Test public void test_interrupted_thread() throws Exception { InterruptThread interruptThread = new InterruptThread(); interruptThread.start(); interruptThread.interrupt(); System.out.println("interrup

  • Java List集合返回值去掉中括号(''[ ]'')的操作

    如下所示: 调用StringUtils工具类的strip()方法去掉中括号"[ ]": StringUtils.strip(word.toString(),"[]") //第一个参数放集合,第二个参数去掉中括号"[]" StringUtils工具类代码: package com.ktamr.common.utils; import com.ktamr.common.core.text.StrFormatter; import java.util.

  • .NET提取 Thread 中返回值详情

    目录 一..NET 2.0+ 二..NET 4.0 + 三..NET 4.5 + 以下文章来源于公众号DotNetCore实战  Igor Bendrup: 关于如何获取 Thread 中的返回值,不同的版本有不同的解决方案. 一..NET 2.0+ 你可以直接使用 Thread 对象,然后你可以使用闭包(声明变量并在 lambda 中捕获它),参考如下代码: object result = null; Thread thread = new System.Threading.Thread(()

  • JS模态窗口返回值兼容问题的完美解决方法

    因系统要兼容原IE已使用的关闭方法,经调试测得,需对window.dialogArguments进行再较验,不然易出问题. function OKEnd(vals) { if (vals == null) vals = "TRUE"; if (typeof (window.opener) == "undefined") { if (typeof (window.dialogArguments) != "undefined") { if (wind

  • 在DWR中实现直接获取一个JAVA类的返回值的两种方法

    第一种实现(来源网上转贴): js 代码 function Test() { var _data = ""; this.getString = function() { //设置成同步 DWREngine.setAsync(false); //调用Java类Test的getString方法,callBackFun为回调函数 JTest.getString(function(data){_data = data;} //重新设置为异步方式 DWREngine.setAsync(true)

  • Java Map.get()返回指定键所映射的值

    Java Map.get()返回指定键所映射的值

    Java 集合类中的 Map.get() 方法返回指定键所映射的值.如果此映射不包含该键的映射关系,则返回 null. 语法: get(Object key)) 参数说明: key:是指定的 Map 集合中的键名. 典型应用 本示例使用 HashMap 类创建 Map 集合对象,并向集合中添加指定的内容,然后使用 get 方法获取指定键名的键值对象.代码如下: public static void main(String[] args){ Map map = new HashMap(); //定

  • Java提示缺少返回语句的解决办法

    Java提示缺少返回值语句怎么办?这里我们给大家提供具体的解决方法. 首先,以下面的程序为例,会看到在控制台有:错误:缺少返回语句的提示. 找到类中定义的方法test中发现,明明已经定义了return,软件依然会提示错误. 将return定义到for循环之外,就会发现,程序不再报错. 原因是因为数组不仅仅可以存放具体的变量值,而且可以不赋给数组任何值. 在数组内容为空的情况,程序是没有报错的,所以需要将return返回值定义到   for 循环之外即可. 关于Java中return缺少返回语句的

  • mybatis中方法返回泛型与resultType不一致的解决

    mybatis中方法返回泛型与resultType不一致的解决

    mybatis方法返回泛型与resultType不一致 当xxxMaaper.java的方法返回值类型是List<A>,而xxxMappper.xml中对应的sql的resultType指定为B对象,这样是不会包错的(即使A与B不存在关系) 原因分析: 1.集合对象原本就是存储对象,可以是不同的对象List 2.直接处理List类型常常会出现类型转换异常,jdk5出现泛型,使得程序员向list中存放相同类型对象 3.泛型作用于编译阶段,仅为了防止类型混乱而出现,类型转换异常 4.mybatis

  • java多线程返回值使用示例(callable与futuretask)

    Callable接口类似于Runnable,从名字就可以看出来了,但是Runnable不会返回结果,并且无法抛出返回结果的异常,而Callable功能更强大一些,被线程执行后,可以返回值,这个返回值可以被Future拿到,也就是说,Future可以拿到异步执行任务的返回值,下面来看一个简单的例子 复制代码 代码如下: package com.future.test; import java.io.FileNotFoundException;import java.io.IOException;i

  • java线程的run()没有返回值怎么办？

    用线程Thread执行一些方法后,需要判断执行是否成功. public void run() {} run( ) 方法返回值是空, 怎么办? 解决方法: Note 使用 call() 方法 Callable接口是 jdk 5 后新增的接口 代码: package com.example.thread; import java.io.IOException; import java.io.InputStream; import java.net.HttpURLConnection; import

随机推荐