相关疑难解决方法(0)

我有一个简单的java ExecutorService运行一些任务对象(实现Callable).

ExecutorService exec = Executors.newSingleThreadExecutor();
List<CallableTask> tasks = new ArrayList<>();
// ... create some tasks
for (CallableTask task : tasks) {
 Future future = exec.submit(task);
 result = (String) future.get(timeout, TimeUnit.SECONDS);
 // TASKS load some classes and invoke their methods (they may create additional threads)
 // ... catch interruptions and timeouts
}
exec.shutdownNow();

在完成所有任务(DONE或TIMEOUT-ed)之后,我尝试关闭执行程序,但它不会停止:exec.isTerminated() = FALSE. 我怀疑某些被执行的任务未正确终止.

是的,我知道执行者的关闭不能保证任何事情:

除尽力尝试停止处理主动执行任务之外,没有任何保证.例如,典型的实现将通过{@link Thread#interrupt}取消,因此任何未能响应中断的任务都可能永远不会终止.

我的问题是,有没有办法确保这些(任务)线程终止？我提出的最佳解决方案是System.exit()在程序结束时调用,但这很简单.

说我有这样一个方法：

synchronized void incrementIndex() {
      index++;
}

我想对这个方法进行单元测试，看看如果多个线程同时尝试增加索引，索引的最终值是否设置正确。假设我不知道方法声明中的“synchronized”关键字（并且我只知道方法的契约），我该如何进行测试？

ps 如果有帮助，我正在使用 Mockito 编写测试用例。