软件编程
位置:首页>> 软件编程>> java编程>> Java并发编程之线程中断

Java并发编程之线程中断

作者:黑夜中的小迷途  发布时间:2022-04-28 02:02:44 

标签:Java,并发,编程,线程中断

线程中断:

void interrupted()方法:中断线程,例如,当线程A运行时,线程B可以调用线程A的interrupted()方法来设置线程的中断标志为true并立即返回。设置标志仅仅是为了设置标志,线程A实际并没有被中断,它会继续往下执行,如果线程A因为调用了wait()方法,join()方法或者sleep()方法而引起的阻塞挂起,这时候若线程B调用线程A的interrupted()方法,线程A回调用这些方法的地方会抛出InterruptedException异常而返回。
boolean isInterrupted()方法:检测当前线程是否被中断,如果是返回true,否则返回false
boolean intertupted()方法:检测当县线程是否被中断,如果是返回true,否则返回false。与isInterrupted()不同的是,该方法如果发现线程被中断,则会清除中断标志。


package com.heiye.learn1;

import java.util.logging.Logger;

public class InterruptedTest {
   public static void main(String[] args) throws InterruptedException {
       Logger logger=Logger.getLogger(InterruptedTest.class.toString());
       Thread thread=new Thread(new Runnable() {
           @Override
           public void run() {
               //如果当前线程被中断则退出循环
               while (!Thread.currentThread().isInterrupted()){
                   logger.warning(Thread.currentThread()+"Hello");
               }
           }
       });

//启动子线程
       thread.start();
       //主线程休眠1s,以便中断当前让子线程输出
       Thread.sleep(1000);
       //中断子线程
       logger.warning("main thread interrupted thread");
       thread.interrupt();
       //等待子线程执行完毕
       thread.join();
       logger.info("main is over");
   }
}

Java并发编程之线程中断

在如上代码中,子线程thread通过检查当前线程中断标志来控制是否退出循环,主线程在休眠1s后调用了threadinterupted()方法设置了中断标志,所以线程thread退出了循环。

下面看一种情况,当线程为了等待一些特定条件的到来时候,一般会使用sleep()方法,wait(),join()方法来阻塞挂起当前线程。下面看一个例子:


package com.heiye.learn1;

import java.util.logging.Logger;

public class InterruptedTest2 {
   public static void main(String[] args) throws InterruptedException {
       Logger logger = Logger.getLogger(InterruptedTest.class.toString());
       Thread threadOne = new Thread(new Runnable() {
           @Override
           public void run() {
               logger.info("threadOne begin sleep 2000 seconds");
               try {
                   Thread.sleep(2000000);
                   logger.info("threadOne awaking");
               } catch (InterruptedException e) {
                   logger.warning("threadOne is interrupted while sleeping");
                   return;
                   //e.printStackTrace();
               }
               logger.warning("threadOne-leaving normally")    ;
           }
       });

threadOne.start();
       //确保子线程进入睡眠状态
       Thread.sleep(1000);
       //打断子线程睡眠,让子线程从sleep返回
       threadOne.interrupt();
       //等待子线程执行完毕
       threadOne.join();
       logger.info("main thread is over");
   }
}

Java并发编程之线程中断

来源:https://www.cnblogs.com/xiaomitu/p/15336239.html

0
投稿

猜你喜欢

手机版 软件编程 asp之家 www.aspxhome.com