主动停止线程的处理办法

迷南。 2022-03-31 04:10 263阅读 0赞

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

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

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

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

public class OrderStateHandler {
    
        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());
    //                SetUpHandler.flag = true;
                }
    
                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。

tips2：碰巧又看到线程池中正好有一个拒绝策略可以丢弃掉最老的任务来执行新任务，

*  AbortPolicy：直接抛出异常。
 *  CallerRunsPolicy：只用调用者所在线程来运行任务。
 *  DiscardOldestPolicy：丢弃队列里最老的一个任务，并执行当前任务。
 *  DiscardPolicy：不处理，丢弃掉。

也就是上面第三个策略DiscardOldestPolicy

static ThreadPoolExecutor threadPoolSecond= new ThreadPoolExecutor(1, 1, 60, TimeUnit.SECONDS, queue2, executingThreadFactory, new ThreadPoolExecutor.DiscardOldestPolicy());// 抛弃策略：丢弃队列里最老的一个任务，并执行当前任务。

于是我创建线程池的时候加上了这个策略，结果跟预想的一样，这玩意只能对阻塞队列起作用，但是没在队列中直接在跑的任务线程依然为所欲为，所以这个方法也不行。