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阻塞...您将不会得到线程的堆积，也不会耗尽内存。相反，积压的任务将坐在[C​​0]的工作队列中，直到其中一个工作线程解除阻塞为止。