Я пытаюсь реализовать TimeoutTask, который завершится по истечении заданного тайм-аута. Вот что у меня есть:
import java.io.BufferedReader;
import java.io.InputStreamReader;
import java.util.Objects;
import java.util.concurrent.Callable;
import java.util.concurrent.ExecutionException;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.FutureTask;
import java.util.concurrent.TimeUnit;
import java.util.concurrent.TimeoutException;
public class TimeoutTask {
private Long timeout;
private TimeUnit unit;
public TimeoutTask(Long timeout, TimeUnit unit) {
this.timeout = timeout;
this.unit = unit;
}
public <T> T execute(Callable<T> callable) {
Objects.requireNonNull(timeout, "Timeout");
Objects.requireNonNull(unit, "Time Unit");
Objects.requireNonNull(callable, "Callable");
ExecutorService service =
Executors.newFixedThreadPool(1);
FutureTask<T> task = new FutureTask<T>(callable);
service.execute(task);
try {
return task.get(timeout, unit);
} catch (InterruptedException | ExecutionException | TimeoutException cause) {
if(cause instanceof TimeoutException) {
System.out.println("\nTimeout occured.");
task.cancel(true);
}
} finally {
System.out.println("Finally called.");
service.shutdownNow();
}
return null;
}
public static void main(String[] args) throws InterruptedException, ExecutionException, TimeoutException {
Callable<String> callable = () -> {
System.out.print("Enter something: ");
BufferedReader consoleReader =
new BufferedReader(new InputStreamReader(System.in));
String str = consoleReader.readLine();
return str;
};
TimeoutTask timeoutTask = new TimeoutTask(Long.valueOf(10), TimeUnit.SECONDS);
timeoutTask.execute(callable);
}
}
Он работает, и я вижу сообщение о тайм-ауте, если ввод не вводится. Однако процесс не останавливается. Ниже приведен снимок экрана с консоли Eclipse, см. Выделенную часть:
Когда я ввожу какие-либо данные, процесс немедленно прекращается. Я вызываю FutureTask#cancel из блока catch, а также из блока finally. Я прошу выключить службу, сделав вызов ExecutorService#shoutDownNow, и я вижу, что он печатает, что наконец вызывается.
- Как я могу остановить выполнение процесса в случае тайм-аута?
- Есть ли лучший подход для этого?
Я использую Java 8.
Ссылка:
Обновлять
В ответе Марко Топольник сказал, что причина не в прерванный Java IO; поэтому я меняю Callable как:
Callable<Long> callable = () -> {
long i = 0;
for(; i <Long.MAX_VALUE;i++){
}
return i;
};
В этом случае произошло то же самое.
Примечание. Callable - это всего лишь образец.
