检索使用 ScheduledExecutorService 计划的任务实例

Question

我在 JEE 环境中获得了用于任务调度的 ScheduledExecutorService 。其中一些任务在被 ScheduledExecutorService.shutdownNow() 中断时会保留打开的资源（例如，使用 Lucene 等第三方库打开文件）。

我知道线程可能不会自行停止执行：停止线程的必须使用的方法是检查中断标志并停止方法执行，并且如果线程被阻塞（例如 wait()、sleep() 等）或者，如果在可中断通道中执行某些 IO 操作，Thread.interrupt() 将引发 InterruptedException。在这两种情况下，都必须执行finally 块。 请参阅： http:// /download.oracle.com/javase/1,5.0/docs/api/java/lang/Thread.html#interrupt%28%29。

显然，我已经尝试在Task类中使用很好实现的finally块来释放资源，但是在某些环境（例如CentOS）中，当线程中断时，finally块不会被执行。然后我在官方 Java 文档中发现了这个非常酷的注释：

注意：如果 JVM 在 try 或 catch 代码执行时退出， 那么finally块可能不会执行。同样，如果线程 执行try或catch代码被中断或杀死，finally 即使应用程序作为一个整体，块也可能无法执行 继续。

因此，我需要的是对所有计划任务的引用，以便在任务类中实现一些强制释放资源的公共方法。我可以从 ScheduledExecutorService 检索对任务类的引用吗？或者您有什么好主意可以更好地解决我的问题吗？

第一个解决方案：包装它！

为 ScheduledExecutorService 创建一个 Wrapper 类并添加如下属性：

private IdentityHashMap<ScheduledFuture<?>, Runnable> taskList;

有了它，我们可以直接访问任何 Runnable 对象，或者通过 >ScheduledFuture 与之相关。对于包装器的实例化，我可以从 Executors.newScheduledThreadPool() 方法获取 ScheduledExecutorService 并将其传递给我的包装器。

另一个解决方案：扩展它！

扩展ScheduledThreadPoolExecutor，添加IdentityHashMap属性并覆盖所有调度或取消作业的方法，以在Map中添加/删除引用。

两种解决方案都有问题？

如果包装器或扩展类的调用者收到 SchedulerFuture 对象，请使用 SchedulerFuture 取消作业;.cancel() 方法是可能的，绕过你的“胶囊”。使用包装器，您可以避免将 SchedulerFuture 引用传递给调用者，但使用扩展类则不能（如果您在扩展类中创建自己的方法，您将得到相同的结果）结果作为包装器，但以一种非常令人困惑的方式）。

优雅的解决方案：您自己的调度程序！感谢 Kaj 指出...

1. 扩展 ScheduledThreadPoolExecutor 以覆盖 decorateTask() 方法
2. 使用 a 的一个实现来装饰 Runnable ScheduledFuture 接口
3. 实现一个自定义的 cancel() 方法，该方法实际上 取消线程，但也操纵 Runnable 对象来强制 资源释放。

查看我的博客 帖子 了解详细信息和代码例子！！！

Answer 1

你有什么安排？任务是什么样的？我发现很难相信finally 块没有被执行。我猜想这是您已安排但尚未开始执行的任务正在泄漏资源（因为它们的finally块不会被执行）

听起来像是CentOS上的一个非常糟糕的VM实现，如果它确实不是的话执行这些finally 块。在任何其他虚拟机实现中都没有听说过这一点。

您可以做的一种选择是，继承 ScheduledThreadPoolExecutor 并重写 decorateTask 方法，以便它们用您的类装饰任务，而不是引用所有计划任务。然后拦截取消调用。