java - 带有 ServletContextListener 的线程池

Question

我想运行一些简单的后台进程计算，但我似乎无法弄清楚。无论我做什么，它都会阻塞。

public class WorkThreadManagerContextLoaderListener implements ServletContextListener {
    private Runnable runnable;
    private WorkManager workManager;

    @Override
    public void contextInitialized(ServletContextEvent event) {
        final WebApplicationContext springContext = WebApplicationContextUtils.getWebApplicationContext(event.getServletContext());
        workManager = (WorkManager) springContext.getBean("workThreadManager");

        runnable = new WorkThreadManagerStartUp(WorkManager);

        runnable.run();
    }

    @Override
    public void contextDestroyed(ServletContextEvent event) {
        workManager.shutDown();
    }
}

之所以存在 WorkThreadManagerStartUp 是因为我不想让它阻塞，所以我将它设为 Runnable 类型，当调用 run() 时，它会启动一个 ExecutorService:

public class UnitOfWorkThreadManagerStartUp implements Runnable {
    private WorkManager workManager;

    public UnitOfWorkThreadManagerStartUp(WorkManager workManager) {
        this.workManager = workManager;
    }

    @Override
    public void run() {
        workManager.startUp();
    }
}

public class WorkThreadManager implements WorkManager {
    @Autowired
    private WorkService workService;

    private final int availableProcessors = Runtime.getRuntime().availableProcessors();
    private final ExecutorService executorService = Executors.newFixedThreadPool(4 * availableProcessors);

    @Override
    public void startUp() {
        // this method always blocks...
    }
}

但是我的解决方案没有按预期工作。我在 Tomcat 7.0.30 上运行。

我想要弄清楚的是如何在后台启动线程池而不停止 Web 应用程序的部署，因为目前由于 startUp() 始终阻塞，它永远无法完全上线。我想简化这个解决方案，如果不需要的话，可能会删除 WorkThreadManagerStartUp 类。

编辑:

我修改了启动类

public class WorkThreadManagerStartUp implements Runnable {
    private WorkManager workManager;

    public WorkThreadManagerStartUp(WorkManager workManager) {
        this.workManager = workManager;
    }

    @Override
    public void run() {
    try {
        while (true) {
                System.out.println("Hello World!");
                Thread.sleep(1000 * 10);
            }
        } catch(InterruptedException e) {
            System.out.println(e.getMessage());
        }
    }
}

虽然这应该在它自己的线程上运行，但Hello World!按预期显示多次，但不允许网络应用程序上线。

Answer 1

查看您的源代码，我没有看到实际创建的任何线程。通常，您会执行以下操作来 fork 线程:

new Thread(new WorkThread(...)).start();

这将在新线程中调用 WorkThread.run() 方法。如果您使用 ExecutorService(通常推荐使用 Thread 的“手动”代码)，那么您会这样做:

executorService.submit(new WorkThread(...));
...
// when done with the service you have to shut it down
executorService.shutdown();

如果您将 WorkManager 类注入(inject)到监听器类中，那么我只需在管理器上添加一个 submit(...) 方法，并在监听器中执行以下操作:

workManager.submit(new WorkThread());

这意味着 WorkThreadManagerStartUp 类不是必需的。您将工作线程或工作单元提交给服务。

就 Spring 而言，我只需让您的 WorkManager 类实现 InitializingBean 和 DisposableBean，以便它可以自行启动和停止其服务。没有理由让另一个 bean 这样做。然后，您可以使用管理器管理的 ExecutorService 将管理器注入(inject)到任何想要运行 WorkThread 的类中。