0

我在关闭 ExecutorService 已终止的应用程序时遇到问题......有什么好的方法来处理这个问题？

public class TradingLock {

    private ExecutorService executorService;
    private List<TradingHaltedListener> listeners=new ArrayList<>();
    public TradingLock(ExecutorService executorService) {
        super();
        this.executorService = executorService;
    }

    public void haltTrading(){
        for (final TradingHaltedListener listener: listeners){
            executorService.execute(new Runnable() {
                @Override
                public void run() {
                    listener.onTradingHalted();
                }
            });
        }
    }
    public synchronized void addTradingHaltedListener(TradingHaltedListener listener){
        this.listeners.add(listener);
    }
}

主类的关闭钩子：

Runtime.getRuntime().addShutdownHook(new Thread() {
        public void run() {
            tradingLock.haltTrading();
        }
    });
4

1 回答 1

1

我发现如果我创建一个扩展 Thread 的类并在addShutdownHook它运行的函数中使用它没有问题。

 public class ShutdownHandler extends Thread {
      public void run(){
           // do all the work to clean up before shutting down
      }
 }

然后将其添加到主类中

 Runtime.getRuntime().addShutdownHook(new ShutdownHandler());

编辑

在阅读了有关 的更多信息后ExecutorService，可能是正在接收 ashutdown或shutdownNow应用程序开始退出时。当addShutdownHook应用程序开始其关闭序列时触发。ExecutorService因此，在您的 Shutdown 挂钩启动之前，它可能已关闭。

于 2012-07-02T11:38:07.800 回答