multithreading - 在 Spring 中停止线程

Question

在我的 Spring 应用程序中，我启动了一个这样的线程。

import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.ApplicationListener;
import org.springframework.context.event.ContextRefreshedEvent;
import org.springframework.context.event.ContextStoppedEvent;
import org.springframework.stereotype.Component;

@Component
public class RunBackgroundServices implements ApplicationListener<ContextRefreshedEvent> {

    private final BackgroundServices backgroundServices;

    private ExecutorService executor;

    @Autowired
    public RunBackgroundServices(BackgroundServices backgroundServices) {
        this.backgroundServices= backgroundServices;
    }

    @Override
    public void onApplicationEvent(ContextRefreshedEvent event) {

        executor = Executors.newSingleThreadExecutor();
        executor.submit(backgroundServices);
    }

    public void onApplicationEvent(ContextStoppedEvent event) {
        backgroundServices.close();
        executor.shutdownNow();
     }
}

这是线程BackGroundServices。

public class BackgroundServices extends Thread {

    @Autowired
    HL7Listener hL7Listener;

    @Autowired
    HISListener hISListener;

    @Autowired
    PollHIS pollHIS;

    @Autowired
    PollPatientPortal pollPatientPortal;

    private static final Logger logger = LoggerFactory.getLogger(BackgroundServices.class);

    public void run() {
        logger.debug("BackgroundServices :: run");
        try {
            hL7Listener.start();
        } catch (InterruptedException e) {
            logger.error(e.getStackTrace().toString());
        }

        try { 
            hISListener.start();
        } catch (InterruptedException e) {
            logger.error(e.getStackTrace().toString());
        }

        while (true) {
            pollHIS.start();
            pollPatientPortal.start();
        }
    }

    public void close(){
        hL7Listener.stop();
        hISListener.stop();
    }
}

但是当我停止服务器时，线程继续在后台运行。我无法控制执行程序，有没有办法停止线程？

Answer 1

调用shutdown或 shutdownNow在 ExecutorService不会停止当前正在执行任务的线程。 shutdownNow将等待所有当前正在执行的任务完成。强行停止线程是一件非常糟糕的事情，没有任何行为良好的 Java 代码会这样做。

如果要停止线程，则需要将某种信号传递给线程，然后您的代码需要读取该信号。 ExecutorService#shutdownNow为你做了一半——它向当前正在执行的线程发送一个中断信号。您的代码已开始处理中断，但未正确实现。

当您收到 InterruptedException , 你不能只记录它并继续前进 - 该异常告诉你你的线程已被中断，它需要完成它正在做的事情并退出(见 Java theory and practice: Dealing with InterruptedException - 一篇非常值得新手和专家阅读的精彩文章一样)。而不是在收到 InterruptedException 时记录错误，您的代码需要退出该方法(例如使用 return )。

在您的 while 循环中，您需要检查线程是否已被中断，如果有则退出。所以你的 run 方法现在变成了这样:

public void run() {
    logger.debug("BackgroundServices :: run");
    try {
        hL7Listener.start();
        hISListener.start();
    } catch (InterruptedException e) {
        logger.error(e.getStackTrace().toString());
        return;
    }

    while (true) {
        if (Thread.currentThread.isInterrupted()) {
            logger.debug("Thread interrupted, exiting");
            return;
        }
        pollHIS.start();
        pollPatientPortal.start();
    }
}

最后一件事 - BackgroundServices不应延长 Thread ，它应该只实现 Runnable . ExecutorService将其视为 Runnable因为 Thread碰巧实现了那个接口(interface)，但是 ExecutorService创建和管理自己的线程。扩展 Thread你自己只会导致困惑。