Jak uzyskać FutureTask, aby powrócić po TimeoutException?
W poniższym kodzie łapię wyjątek TimeoutException po 100 sekundach zgodnie z przeznaczeniem. W tym momencie oczekiwałbym, że kod wyjdzie z main i program się zakończy, ale nadal drukuje na konsoli. Jak mogę przerwać wykonywanie zadania po przekroczeniu limitu czasu?
private static final ExecutorService THREAD_POOL = Executors.newCachedThreadPool();
private static <T> T timedCall(Callable<T> c, long timeout, TimeUnit timeUnit) throws InterruptedException, ExecutionException, TimeoutException {
FutureTask<T> task = new FutureTask<T>(c);
THREAD_POOL.execute(task);
return task.get(timeout, timeUnit);
}
public static void main(String[] args) {
try {
int returnCode = timedCall(new Callable<Integer>() {
public Integer call() throws Exception {
for (int i=0; i < 1000000; i++) {
System.out.println(new java.util.Date());
Thread.sleep(1000);
}
return 0;
}
}, 100, TimeUnit.SECONDS);
} catch (Exception e) {
e.printStackTrace();
return;
}
}