java - Java Future 重复超时导致 JVM 内存不足

Question

我们的 Java 应用程序遇到一个问题，当它尝试写入位于 NFS 共享上的日志文件并且 NFS 共享已关闭时，它会无限期地阻塞。

我想知道我们是否可以通过让 Future 执行超时的写入操作来解决这个问题。这是我编写的一个小测试程序:

public class write_with_future {
    public static void main(String[] args) {
        int iteration=0;
        while (true) {
            System.out.println("iteration " + ++iteration);

            ExecutorService executorService = Executors.newSingleThreadExecutor();
            Future future = executorService.submit(new Runnable() {
                public void run() {
                    try {
                        Category fileLogCategory = Category.getInstance("name");
                        FileAppender fileAppender = new FileAppender(new SimpleLayout(), "/usr/local/app/log/write_with_future.log");
                        fileLogCategory.addAppender(fileAppender);
                        fileLogCategory.log(Priority.INFO, System.currentTimeMillis());
                        fileLogCategory.removeAppender(fileAppender);
                        fileAppender.close();
                    }
                    catch (IOException e) {
                        System.out.println("IOException: " + e);
                    }
                }
            });

            try {
                future.get(100L, TimeUnit.MILLISECONDS);
            }
            catch (InterruptedException ie) {
                System.out.println("Current thread interrupted while waiting for task to complete: " + ie);
            }
            catch (ExecutionException ee) {
                System.out.println("Exception from task: " + ee);
            }
            catch (TimeoutException te) {
                System.out.println("Task timed out: " + te);
            }
            finally {
                future.cancel(true);
            }

            executorService.shutdownNow();
        }
    }
}

当我以最大堆大小 1 MB 运行该程序并且 NFS 共享已启动时，该程序在我停止之前能够执行超过 100 万次迭代。

但是当我以最大堆大小为 1 MB 运行该程序并且 NFS 共享已关闭时，该程序执行了 584 次迭代，每次都会遇到 TimeoutException，然后失败并显示 java.lang.OutOfMemoryError错误。所以我想即使 future.cancel(true)和executorService.shutdownNow()正在被调用，执行器线程在写入时被阻塞并且不响应中断，并且程序最终耗尽内存。

有什么办法可以清理被阻塞的执行线程吗？

Answer 1

如果出现 Thread.interrupt() 不会中断 NFS 文件上 I/O 操作中阻塞的线程。您可能想要检查 NFS 挂载选项，但我怀疑您无法解决该问题。

但是，您当然可以防止它导致 OOME。您得到这些的原因是您没有使用 ExecutorService ，因为它们的设计目的是使用它们。您所做的就是重复创建和关闭单线程服务。您应该做的是使用有界线程池创建实例并将其用于所有任务。如果您这样做，如果其中一个线程花费很长时间...或者在 I/O 中被阻塞...您将不会积累线程，并且会耗尽内存。相反，积压的任务将位于 ExecutorService 的工作队列中，直到其中一个工作线程解除阻塞。