并发编程（七）线程如何优雅地终止

/**
 * 设置标识位停止线程
 */
public class MyThreadStop {

    //计数
    private static int count = 0;
    //退出标识符
    public static boolean exit = false;


    /**
     * 核心线程
     */
    public static void main(final String[] arguments) throws InterruptedException {
        Thread t = new Thread(new TestThread());
        t.start();
    }

    /**
     * 同步方法
     */
    public static synchronized void countNum() {
        for (int i = 0; i < 100000; i++) {
            if (count >= 500000) {
                exit = true; //修改标志位，退出线程
            } else {
                count++;
                System.out.println(count);
            }
        }
    }

    /**
     * 线程实体（实现Runnable接口）
     */
    static class TestThread implements Runnable {

        public void run() {
            while (!exit) {//当标识符没设置停止时，一直做参数递增
                countNum();
            }
        }
    }
}

/**
 * interrupt()方法停止线程
 */
public class MyThreadStop {

    //计数器
    private static int count = 0;

    /**
     * 核心线程
     */
    public static void main(final String[] arguments) throws InterruptedException {
        Thread t = new Thread(new TestThread());
        t.start();
        //休眠一会儿，然后中断
        t.sleep(200);
        t.interrupt();
    }

    /**
     * 同步方法
     */
    public static synchronized void countNum() {
        for (int i = 0; i < 500000; i++) {
            count++;
            System.out.println(count);
        }
    }

    /**
     * 线程实体（实现Runnable接口）
     */
    static class TestThread implements Runnable {
        public void run() {
            countNum();
        }
    }
}

/**
 * interrupt()方法停止线程
 */
public class MyThreadStop {

    //计数器
    private static int count = 0;

    /**
     * 核心线程
     */
    public static void main(final String[] arguments) throws InterruptedException {
        Thread t = new Thread(new TestThread());
        t.start();
        //休眠一会儿，然后中断
        t.sleep(200);
        t.interrupt();
    }


    /**
     * 线程实体（实现Runnable接口）
     */
    static class TestThread implements Runnable {
        public void run() {
            for (int i = 0; i < 500000; i++) {
                //判断线程是否被通知中断
                if (Thread.currentThread().isInterrupted()) {
                    //处理中断逻辑
                    break;
                }
                count++;
                System.out.println(count);
            }
        }
    }
}