如何完全停止 ExecutorService？

Question

我在 SO 上问了一个问题 here 并得到了解决方案 there。但是在运行该解决方案之后，它似乎无法按预期工作。

换句话说，我正在遍历一堆 Java 文件并逐个分析它们。我的分析算法可能需要 1 秒到 5-10 小时，可能。但如果分析在 10 分钟内还没有完成，我想完成分析。程序长时间运行也会产生内存不足的异常。

这是我正在使用的代码。

for循环：

for (File file : files)
{
String fileName = file.getName();
String filePath = file.getAbsolutePath();

ExecutorService executor = Executors.newSingleThreadExecutor();
Task ts = new Task(filePath);
Future<String> future = executor.submit(ts);
try {
    System.out.println("@@ Started.. " + fileName );
    System.out.println(future.get(10, TimeUnit.MINUTES));
    System.out.println("@@ Finished!" + fileName);
} catch (TimeoutException e) {
    System.out.println("@@ Terminated!" + fileName);
} catch (InterruptedException e) {
    // TODO Auto-generated catch block
    e.printStackTrace();
} catch (ExecutionException e) {
    // TODO Auto-generated catch block
    e.printStackTrace();
}
finally{
    shutdownAndAwaitTermination(executor, future);
    future.cancel(true);
}
}

shutdownAndAwaitTermination(,) 方法：

// http://docs.oracle.com/javase/7/docs/api/java/util/concurrent/ExecutorService.html
public static void  shutdownAndAwaitTermination(ExecutorService pool, Future<String> futureObj) {
       pool.shutdown(); 
       try {
         if (!pool.awaitTermination(60, TimeUnit.SECONDS)) {
           pool.shutdownNow(); 
           if (!pool.awaitTermination(60, TimeUnit.SECONDS))
           {
               System.err.println("Pool did not terminate");
           }
         }
       } catch (InterruptedException ie) {
         pool.shutdownNow();
         Thread.currentThread().interrupt();
       }
     }

}

任务类：

class Task implements Callable<String> {

    String fName = "";
    Task(String file)
    {
        fName = file;
    }
    @Override
    public String call() throws Exception {

        while(!Thread.currentThread().isInterrupted())
        {
    // Long running program on file fName.          
       }
        return "Ready!";
    }
}

我收到以下异常：

@@ Started.. file1.java
@@ Terminated!file1.java
Pool did not terminate
@@ Started.. file2.java
java.util.concurrent.ExecutionException: java.util.ConcurrentModificationException
    at java.util.concurrent.FutureTask$Sync.innerGet(FutureTask.java:262)
    at java.util.concurrent.FutureTask.get(FutureTask.java:119)
    at controller.Controller.main(Controller.java:75)
Caused by: java.util.ConcurrentModificationException
    at java.util.ArrayList$Itr.checkForComodification(ArrayList.java:819)
    at java.util.ArrayList$Itr.next(ArrayList.java:791)
    at iterator.CFGIterator.combineCFGs(CFGIterator.java:137)
    at iterator.CFGIterator.setOneCFG(CFGIterator.java:92)
    at iterator.CFGIterator.<init>(CFGIterator.java:41)
    at cfg.ClassObj.iterator(ClassObj.java:47)
    at taintanalyzer.TaintAnalyzer.analyze(TaintAnalyzer.java:196)
    at cfg.ClassObj.accept(ClassObj.java:65)
    at taintanalyzer.TaintAnalyzer.analyze(TaintAnalyzer.java:348)
    at controller.Task.call(Controller.java:140)
    at controller.Task.call(Controller.java:1)
    at java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:334)
    at java.util.concurrent.FutureTask.run(FutureTask.java:166)
    at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
    at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
    at java.lang.Thread.run(Thread.java:722)

Answer 1

你的问题在这里：

for (File file : files) { //... }

我猜你使用ArrayList<File> 来保存许多对象文件。但是，数据结构ArrayList 不是线程安全的。

ArrayList Java Doc

请注意，此实现不同步。如果多个线程同时访问一个 ArrayList 实例，并且至少有一个线程在结构上修改了列表，则必须外部同步

您可以尝试使用CopyOnWriteArrayList 代替ArrayList 来处理大型列表并获得性能。

编辑：

如果你想看到第一个文件运行结束并坚持使用awaiTermination，你需要将超时参数设置得足够大。

   pool.shutdown(); 
   try {
     // Wait longer, example 6000 seconds for existing task to terminate
     if (!pool.awaitTermination(6000, TimeUnit.SECONDS)) {
       pool.shutdownNow(); 
       if (!pool.awaitTermination(6000, TimeUnit.SECONDS))
       {
           System.err.println("Pool did not terminate");
       }
     }
   } catch (InterruptedException ie) {
     pool.shutdownNow();
     Thread.currentThread().interrupt();
   }