JAVA线程的interrupt

简介:
  interrupt() 只是改变中断状态而已.  interrupt() 不会中断一个正在运行的线程。这一方法实际上完成的是,给受阻塞的线程抛出一个中断信号,
    这样受阻线程就得以退出阻塞的状态。更确切 的说,如果线程被Object.wait, Thread.joinThread.sleep三种方法之一阻塞,    那么,它将接收到一个中断异常InterruptedException),从而提早地终结被阻塞状态
    如果线程没有被阻塞,这时调用interrupt()将不起作用;否则,线程就将得到InterruptedException异常(该线程必须事先预备好处理此状况),接着逃离阻塞状态。
    线程A在执行sleep,wait,join时,线程B调用线程A的interrupt方法,的确这一个时候A会有InterruptedException 异常抛出来.
    但这其实是在
sleep,wait,join这些方法内部会不断检查中断状态的值,而自己抛出的InterruptedException
    如果线程A正在执行一些指定的操作时如赋值,for,while,if,调用方法等,都不会去检查中断状态
    ,所以线程A不会抛出 
InterruptedException,而会一直执行着自己的操作.
    当线程A终于执行到
wait(),sleep(),join()时,才马上会抛出 InterruptedException.
    若没有调用sleep(),wait(),join()这些方法,即没有在线程里自己检查中断状态自己抛出InterruptedException的 话,
    那InterruptedException是不会被抛出来的. 

        具体使用见实例1,实例2。
注意1:当线程A执行到wait(),sleep(),join()时,抛出InterruptedException后,中断状态已经被系统复位了
线程A调用Thread.interrupted()返回的是false

public static boolean interrupted ()

Since:  API Level 1

Returns a boolean indicating whether the current Thread ( currentThread()) has a pending interrupt request ( true) or not (false). It also has the side-effect of clearing the flag.

Returns
  • boolean indicating the interrupt status

public boolean isInterrupted ()

Since:  API Level 1

Returns a boolean indicating whether the receiver has a pending interrupt request (true) or not ( false)

Returns
  • boolean indicating the interrupt status
1. sleep() & interrupt()
     线程A 正在使用sleep()暂停着:  Thread.sleep(100000);
    如果要取消他的等待状态,可以在正在执行的线程里(比如这里是B)调用
        a.interrupt();
    令线程A放弃睡眠操作,这里a是线程A对应到的Thread实例
    当在sleep中时 线程被调用interrupt()时,就马上会放弃暂停的状态.并抛出
InterruptedException .丢出异常的,是A线程.
2. wait() & interrupt()
    线程A调用了wait()进入了等待状态,也可以用interrupt()取消.
    不过这时候要小心锁定的问题.线程在进入等待区, 会把锁定解除,当对等待中的线程调用 interrupt()
    ,会 先重新获取锁定,再抛出异常.在获取锁定之前,是无法抛出异常的.
3. join() & interrupt()
    当线程以join()等待其他线程结束时,当它被调用interrupt(),它与sleep()时一样, 会马上跳到 catch 块里. 
    注意 ,是对谁调用interrupt()方法,一定是调用被阻塞线程的interrupt方法.如在线程a中调用来线程t.join().
    则a会等t执行完后在执行t.join后的代码,当在线程b中调用来 a.interrupt()方法,则会抛出InterruptedException,当然join()也就被取消了。

实例1:
     static void  interruptDemo()
    {
        Thread t1=new Thread(new InterruptDemoRunnable(),"first");
        Thread t2=new Thread(new InterruptDemoRunnable(t1),"second");
        t1.start();
        t2.start();

    }
class  InterruptDemoRunnable implements Runnable
{
    long id=0;
    static long count=0;
    Thread t;
    InterruptDemoRunnable()
    {
        this(null);
    }
    InterruptDemoRunnable(Thread t)
    {
        id=count++;
        this.t=t;
    }
    boolean blRun=true;
     public void  run()
    {    int cnt=0;
          while ( blRun)
        {
            if(t!=null)
            {
                if(cnt==2)
                {
                    t.interrupt();
                    if( t.isInterrupted())
                        System.out.println("set the thread "+t.getName()+" to be Interrupted");
                }
                    
            }
            else
            {    
                try
                {
                    Thread.sleep(1000);
                }
                catch(InterruptedException e)
                {
                    System.out.println("First Interrupted when sleep");
                    System.out.println( "Interrupted is "+Thread.interrupted());//@1
                }
                try
                {
                    Thread.sleep(1);
                }
                catch(InterruptedException e)
                {
                    System.out.println("second Interrupted when sleep");
                }
            }
            System.out.println(id+"run"+cnt);
            cnt++;
            if(cnt==5)
            {
                blRun=false;            
            }
        }
            System.out.println("thread:"+id+"exit");
    }
}
注意1:当线程A执行到wait(),sleep(),join()时,抛出InterruptedException后,中断状态已经被系统复位了。
线程AThread.interrupted()返回的是false
实例2:
     static void  interruptDemo()
    {
        Thread t1=new InterruptDemoThread();
        t1.setName("t1");
        Thread t2=new InterruptDemoThread(t1);
        t1.setName("t2");
        t1.start();
        t2.start();
    }

class  InterruptDemoThread extends Thread
{
    long id=0;
    static long count=0;
    Thread t;
    InterruptDemoThread()
    {
        this(null);
    }

    InterruptDemoThread(Thread t)
    {
        id=count++;
        this.t=t;
    }
    boolean blRun=true;
   
 public void  run()
    {    int cnt=0;
        
while (blRun)
        {
            if(t!=null)
            {
                if(cnt==2)
                {
                    t.interrupt();
                    if( t.isInterrupted() )
                        System.out.println("set the thread "+t.getName()+" to be Interrupted");
                }
                    
            }
            else if( isInterrupted() )@1
            {    
                /*Thread.interrupted();//@2
                System.out.println("after interrupted(),the state of Interrupted is "+isInterrupted());*/

                try{
                    Thread.sleep(1);
                }
                catch(InterruptedException e)
                {
                    System.out.println("Interrupted when sleep");
                    System.out.println( "Interrupted is "+Thread.interrupted());
                }
            }
            Thread.yield();
            System.out.println(id+"run"+cnt);
            cnt++;
            if(cnt==5)
            {
                blRun=false;            
            }
        }
            System.out.println("thread:"+id+"exit");
    }
}
注意1:如果线程被调用了interrupt(),那么如果此次该线程并不在wait(),sleep(),join()时,
下次执行 wait(),sleep(),join()时,一样会抛出InterruptedException,当然抛出后该线程的中断状态也回被系统复位。
注意2:我们可以 手动的使用Thread.interrupted()来使当前线程的中断状态系统复位(即清除中断状态)
相关文章
|
11天前
|
监控 安全 Java
在 Java 中使用线程池监控以及动态调整线程池时需要注意什么?
【10月更文挑战第22天】在进行线程池的监控和动态调整时,要综合考虑多方面的因素,谨慎操作,以确保线程池能够高效、稳定地运行,满足业务的需求。
88 38
|
8天前
|
安全 Java
java 中 i++ 到底是否线程安全?
本文通过实例探讨了 `i++` 在多线程环境下的线程安全性问题。首先,使用 100 个线程分别执行 10000 次 `i++` 操作,发现最终结果小于预期的 1000000,证明 `i++` 是线程不安全的。接着,介绍了两种解决方法:使用 `synchronized` 关键字加锁和使用 `AtomicInteger` 类。其中,`AtomicInteger` 通过 `CAS` 操作实现了高效的线程安全。最后,通过分析字节码和源码,解释了 `i++` 为何线程不安全以及 `AtomicInteger` 如何保证线程安全。
java 中 i++ 到底是否线程安全?
|
12天前
|
Java 调度
[Java]线程生命周期与线程通信
本文详细探讨了线程生命周期与线程通信。文章首先分析了线程的五个基本状态及其转换过程,结合JDK1.8版本的特点进行了深入讲解。接着,通过多个实例介绍了线程通信的几种实现方式,包括使用`volatile`关键字、`Object`类的`wait()`和`notify()`方法、`CountDownLatch`、`ReentrantLock`结合`Condition`以及`LockSupport`等工具。全文旨在帮助读者理解线程管理的核心概念和技术细节。
29 1
[Java]线程生命周期与线程通信
|
2天前
|
存储 设计模式 分布式计算
Java中的多线程编程:并发与并行的深度解析####
在当今软件开发领域,多线程编程已成为提升应用性能、响应速度及资源利用率的关键手段之一。本文将深入探讨Java平台上的多线程机制,从基础概念到高级应用,全面解析并发与并行编程的核心理念、实现方式及其在实际项目中的应用策略。不同于常规摘要的简洁概述,本文旨在通过详尽的技术剖析,为读者构建一个系统化的多线程知识框架,辅以生动实例,让抽象概念具体化,复杂问题简单化。 ####
|
3天前
|
Java 开发者
在Java多线程编程的世界里,Lock接口正逐渐成为高手们的首选,取代了传统的synchronized关键字
在Java多线程编程的世界里,Lock接口正逐渐成为高手们的首选,取代了传统的synchronized关键字
19 4
|
3天前
|
消息中间件 供应链 Java
掌握Java多线程编程的艺术
【10月更文挑战第29天】 在当今软件开发领域,多线程编程已成为提升应用性能和响应速度的关键手段之一。本文旨在深入探讨Java多线程编程的核心技术、常见问题以及最佳实践,通过实际案例分析,帮助读者理解并掌握如何在Java应用中高效地使用多线程。不同于常规的技术总结,本文将结合作者多年的实践经验,以故事化的方式讲述多线程编程的魅力与挑战,旨在为读者提供一种全新的学习视角。
23 3
|
10天前
|
安全 Java
在 Java 中使用实现 Runnable 接口的方式创建线程
【10月更文挑战第22天】通过以上内容的介绍,相信你已经对在 Java 中如何使用实现 Runnable 接口的方式创建线程有了更深入的了解。在实际应用中,需要根据具体的需求和场景,合理选择线程创建方式,并注意线程安全、同步、通信等相关问题,以确保程序的正确性和稳定性。
|
4天前
|
安全 Java 调度
Java中的多线程编程入门
【10月更文挑战第29天】在Java的世界中,多线程就像是一场精心编排的交响乐。每个线程都是乐团中的一个乐手,他们各自演奏着自己的部分,却又和谐地共同完成整场演出。本文将带你走进Java多线程的世界,让你从零基础到能够编写基本的多线程程序。
17 1
|
8天前
|
缓存 Java 调度
Java中的多线程编程:从基础到实践
【10月更文挑战第24天】 本文旨在为读者提供一个关于Java多线程编程的全面指南。我们将从多线程的基本概念开始,逐步深入到Java中实现多线程的方法,包括继承Thread类、实现Runnable接口以及使用Executor框架。此外,我们还将探讨多线程编程中的常见问题和最佳实践,帮助读者在实际项目中更好地应用多线程技术。
17 3
|
10天前
|
监控 安全 Java
Java多线程编程的艺术与实践
【10月更文挑战第22天】 在现代软件开发中,多线程编程是一项不可或缺的技能。本文将深入探讨Java多线程编程的核心概念、常见问题以及最佳实践,帮助开发者掌握这一强大的工具。我们将从基础概念入手,逐步深入到高级主题,包括线程的创建与管理、同步机制、线程池的使用等。通过实际案例分析,本文旨在提供一种系统化的学习方法,使读者能够在实际项目中灵活运用多线程技术。