美文网首页
AQS研究系列(二)--线程状态和interrupt()、int

AQS研究系列(二)--线程状态和interrupt()、int

作者: 爱编程的凯哥 | 来源:发表于2019-08-12 19:35 被阅读0次

    一、先回忆下线程状态图

    线程状态

    如上图,
    线程的状态主要有五个状态new(新生)、runnable(可执行)、running(运行)、blocked(等待)、Dead(死亡).下面让我们听个线程的故事

    二、讲个线程的故事:

            从前,有个叫凯凯的线程,出生在一个叫江州的线程池中.出生后被送到了一个叫Runnable的候车间,她进来后发现候车间有和很多和她一样的线程.过了一会,候车间的门开了,进来一个叫车间主任的人,他把手里拿着一个包裹,给了旁边一个线程D,让线程D随后进入了一个 cpu的车间.过了一段时间后线程D又回到了 Runnable车间.车间主任来来回回几次,终于轮到凯凯干活了.凯凯拿着属于自己的数据包,进入cpu车间.
          此时凯凯发现工作步骤分成很多步骤,需要进入一个又一个叫各种方法名的房间进行处理,按照领导的指挥开始干活.但干到一半时,发现需要进入一个叫afterProcess的房间,但这个车间们被锁上了,需要用钥匙才能打开.但发现此时钥匙正在另一个线程手中,所以凯凯此时进不去此房间, 就被车间主任带到了一个锁等待池的房间.凯凯发现这个房间里有几个敌视的目光看向自己,原来他们也是需要等那把钥匙进入afterProcess等人.
          过了一会,门开了,车间主任进来说,钥匙用完了,该下一个人.此时所有人疯了似的疯抢钥匙,费了半天劲,凯凯终于抢到钥匙,凯凯又被带了runnable房间,说下次到你干活的时间,你直接进入afterProcess房间继续你的工作即可.
          就这样,一会又轮到凯凯继续工作了.凯凯直接进入A继续工作.过了一会,发现在执行o.await()的地方,需要等待别人的通知才能继续工作,然后她就只能交出了钥匙,可怜的被带到了一个叫等待池的地方.等啊等,等啊等,终于听到有人通过喇叭告诉她,现在可以继续干活了.但哪里料到,他先又被带到了锁等待池中去拼抢到那个锁钥匙才行.就这样凯凯又经历了上面的抢钥匙的过程,抢到钥匙后,进入runnable房间,排队等待车间主任叫自己的号.
          凯凯终于再次被叫到,并且这次顺利的完成了自己的工作.他被送回了故乡那个叫江州的线程池.但回家的路上她看到许多没有家的孩子(非线程池创建),工作完后被一个个处死.....凯凯吓的瑟瑟发抖,庆幸自己是有家的保护的.

    三 interrupt()、interrupted()、isInterrupted 使用

    • interrupt() 方法是向其线程发送一个信号,将此线程设置为中断状态.此操作对于运行中(running状态)的线程是不起作用的,又图也可以看出,对于处理blocked阻塞状态的线程会起作用.被阻塞的线程检测到此标志,会根据自己的处理逻辑进行判断,如sleep()中会抛出异常,等待池中的线程会进入锁池...

    • interrupted()是静态方法:内部实现是调用的当前线程的isInterrupted(),并且会重置当前线程的中断状态

    • isInterrupted()是实例方法,是调用该方法的对象所表示的那个线程的isInterrupted(),不会重置当前线程的中断状态

    下面看下代码测试:

        public static void main(String[] args) throws IOException {
    
            //首先interrupted()返回当前线程是否为中断状态,如果是此时将会清空中断状态
            boolean interrupted = Thread.interrupted();
    
            //此处手动将当前线程置为中断状态
            Thread.currentThread().interrupt();
    
            //调用isInterrupted方法查询当前线程是否为状态,不会清空此状态
            boolean interrupted1 = Thread.currentThread().isInterrupted();
    
            // 返回当前中断状态,清空中断状态
            boolean interrupted2 = Thread.interrupted();
    
            boolean interrupted3 = Thread.currentThread().isInterrupted();
    
    
            System.out.println("调用interrupted()查询线程是否为中断状态="+interrupted);
            System.out.println("调用isInterrupted()查询线程是否为中断状态="+interrupted1);
            System.out.println("调用interrupted()查询线程是否为中断状态,并清空状态="+interrupted2);
            System.out.println("调用iisInterrupted判断当前线程状态="+interrupted3);
    
    
        }
    
    

    输出结果如下:

    调用interrupted()查询线程是否为中断状态=false
    调用isInterrupted()查询线程是否为中断状态=true
    调用interrupted()查询线程是否为中断状态,并清空状态=true
    调用iisInterrupted判断当前线程状态=false
    

    AQS研究系列(一)--Unsafe使用
    AQS研究系列(三)--AbstractQueuedSynchronizer源码分析

    相关文章

      网友评论

          本文标题:AQS研究系列(二)--线程状态和interrupt()、int

          本文链接:https://www.haomeiwen.com/subject/fidudctx.html