Java并发编程之线程中断

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");
    }
}

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");
    }
}