2019-01-03

众所周知，开启的线程会自生自灭，运行完后线程池会回收线程以便再次利用，但是总有那么一些情况需要主动停止线程。本人在网上查找了相关内容，没有找到任何答案，于是决定自己想办法解决。

先描述一下为什么会有停止线程的需求，有这样的一个业务场景：1、客户端可以在任务开启后随时关闭运行的任务，这里得用个线程持续监听客户端任务。2、程序可以重复接受任务并运行，结合场景1，如果关闭运行的任务就会抛出异常，更通俗的讲，任何异常都会导致程序挂掉，这样就无法重复接受任务运行了，于是不能用主线程跑任务，还得开一个线程来单独跑任务。3、线程开启后运行任务的过程中会遇到各种阻塞，客户端需要有响应线程才会继续执行。

介绍完以上的业务场景为什么需要主动停止线程的需求就应运而生了，因为线程会阻塞，所以会不断开启新的线程来执行任务，即使线程池数量再多也会有线程不够的情况，而且内存使用量会越来越多，最终导致内存溢出。

那么如何才能主动停止线程呢？

private static BlockingQueue queue1 = new LinkedBlockingDeque(5);
private static BlockingQueue queue2 = new LinkedBlockingDeque(5);
private static OrderListeningThreadFactory listeningThreadFactory = new OrderListeningThreadFactory("监听任务事件");
private static OrderExecutingThreadFactory executingThreadFactory = new OrderExecutingThreadFactory("执行任务事件");
private static ThreadPoolExecutor threadPoolFirst = new ThreadPoolExecutor(1, 5, 60, TimeUnit.SECONDS, queue1, listeningThreadFactory);
static ThreadPoolExecutor threadPoolSecond;

static OrderTaskForExecuting task;

public static void doListening(WebDriver driver, String orderId) {
    OrderTaskForListening task = new OrderTaskForListening(driver, orderId);
    threadPoolFirst.execute(task);
}

public static void doExecuting(String orderId, String account, String password) {
    threadPoolSecond = new ThreadPoolExecutor(1, 5, 60, TimeUnit.SECONDS, queue2, executingThreadFactory);
    task = new OrderTaskForExecuting(orderId, account, password);
    threadPoolSecond.execute(task);
}

上面这段代码就是之前业务场景的实现，一个线程用来做监听，一个线程用来跑任务。现在的问题是，如何在监听线程监听到客户端停止任务的动作后把执行的线程给主动停掉？

上面的代码做中两个动作的代码有些不一样，doListening中的线程池是在方法外定义好的，而doExecuting是在方法里new了一个新的线程池，这是为后面做准备的，我们再来看下面这段代码就明白了：

@Override
    public void run() {
        log.info("启动一个新的线程，判断订单是否已经结束 " + new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new Date()));
        while (true) {
            JSONObject responseMessage3 = null;
            try {
                responseMessage3 = RestTemplateUtil.restTemplateUtil(TSY.TSY_LISTENING_ORDER_STATUS, orderId, TSY.TSY_DEVICE_TYPE);
            } catch (InterruptedException e) {
                log.error(e.getMessage());
            }
            if (responseMessage3.get("msg").toString().equals("订单结束") || responseMessage3.get("msg").toString().equals("订单id为空")) {
                log.info(">>>>>>>>>>>>>>>>>>>>>总共执行任务次数（包括手动取消的）：" + ++SetUpHandler.taskCount + " 次");
                log.info("跳出循环");
                break;
            }
        }
        log.info("任务结束，关闭webDriver");
        driver.close();
        driver.quit();
        SetUpHandler.flag = true;
        // TODO: 2018/12/30 订单被手动结束后，先立即把线程池关闭，后面再调用的时候重新创建一个，这是目前唯一能解决立即销毁线程的权宜之计了
        OrderStateHandler.threadPoolSecond.shutdownNow();
    }

这是具体执行监听事件动作的方法体，持续发送请求，用responseMessage来接收，一旦发现请求中有结束的动作则把任务结束掉，最关键的一步是最后一段代码，这里我直接把执行任务线程给停掉了，而且是即刻停止（shutdown()还会等待运行的线程执行完，而shutdownNow()会立刻停掉所有线程，不管有没有在执行），而且我之前定义的时候执行线程池为静态变量，只有一份，所以可以通过类名来直接引用来执行关闭线程池的动作，下次调用执行任务动作会重新new一个线程池，总的来说就是用关闭线程池的方法来间接停止线程。

tips：如果在死循环中有try-catch语句的，碰巧停止线程的地方就在死循环的try语句块中，那么这个线程不会停止，会一直执行，我也不清楚是问什么，下面有两种解决办法，第一：在catch中加入break来跳出死循环，第二，不要用try-catch改为向上抛语句throws Exception。

原文：https://blog.csdn.net/javaer_lee/article/details/85597999