确定ExecutorService的关闭时间

发布于 2024-12-05 16:53:49 字数 421 浏览 0 评论 0原文

我有一个 ExecutorService 来处理一些任务。客户端线程可以调用ExecutorService上的shutdown()。我想在 ExecutorService 完全关闭后运行一些清理代码。是否有一种机制可以在 ExecutorService 完成关闭后运行回调方法。

注意：

我无法调用shutdownNow()
清理代码必须在shutdown()完成后运行。
ExecutorService 是一个 newCachedThreadPoolExecutor()；

原文

分享到QQ

分享到微博

如果你对这篇内容有疑问，欢迎到本站社区发帖提问参与讨论，获取更多帮助，或者扫码二维码加入 Web 技术交流群。

发布评论

需要登录才能够评论，你可以免费注册一个本站的账号。

负佳期 2024-12-12 16:53:49

启动另一个线程/executor-managed-runnable来检查ExecutorService.awaitTermination(...) 在循环中的 try-catch 语句中直到返回 true，然后运行关闭处理代码。该循环是必要的，因为该方法在中断时可能会过早返回。

像这样的东西：

public class ShutdownHandler implements Runnable {

    private final ExecutorService service;

    public ShutdownHandler(final ExecutorService service) {
        this.service = service;
    }

    @Override
    public void run() {
        boolean terminated = false;
        while (!terminated) {
            try {
                terminated = service.awaitTermination(Long.MAX_VALUE, TimeUnit.MILLISECONDS);
            } catch (final InterruptedException ex) {
                // check again until terminated
            }
        }

        // your shutdown handling code here
    }
}

Start another thread/executor-managed-runnable that checks ExecutorService.awaitTermination(...) in a try-catch statement in a loop until it returns true, then run your shutdown handling code. The loop is necessary because the method might return prematurely when interrupted.

Something like this:

public class ShutdownHandler implements Runnable {

    private final ExecutorService service;

    public ShutdownHandler(final ExecutorService service) {
        this.service = service;
    }

    @Override
    public void run() {
        boolean terminated = false;
        while (!terminated) {
            try {
                terminated = service.awaitTermination(Long.MAX_VALUE, TimeUnit.MILLISECONDS);
            } catch (final InterruptedException ex) {
                // check again until terminated
            }
        }

        // your shutdown handling code here
    }
}

回复收藏 0 原文

[旋木] 2024-12-12 16:53:49

我会扩展并覆盖：

public class MyExecutorService extends ThreadPoolExecutor {
    @Override
    public void shutdown() {
        super.shutdown();
        // do what you need to do here
    }
}

类似的东西

I would extends and override:

public class MyExecutorService extends ThreadPoolExecutor {
    @Override
    public void shutdown() {
        super.shutdown();
        // do what you need to do here
    }
}

Something like that

回复收藏 0 原文