O método Future.cancel () não está funcionando
O código que tenho cria uma instância de Callable e usando ExecutorService um novo segmento está sendo criado. Eu quero matar esse segmento após determinado período de tempo se o segmento não for feito com sua execução. Depois de passar pela documentação do jdk, percebi que o método Future.cancel () pode ser usado para interromper a execução do thread, mas para meu espanto não está funcionando. É claro que o método future.get () está enviando uma interrupção para o Thread após o tempo estipulado (no meu caso são 2 segundos) e até mesmo o thread está recebendo esta interrupção, mas esta interrupção está ocorrendo apenas quando o thread é concluído com sua execução completamente. Mas eu quero matar o fio depois de 2 segundos.
Alguém poderia me ajudar como conseguir isso.
Código da classe Testclass:
====================================
public class TestExecService {
public static void main(String[] args) {
//checkFixedThreadPool();
checkCallablePool();
}
private static void checkCallablePool()
{
PrintCallableTask task1 = new PrintCallableTask("thread1");
ExecutorService threadExecutor = Executors.newFixedThreadPool(1);
Future<String> future = threadExecutor.submit(task1);
try {
System.out.println("Started..");
System.out.println("Return VAL from thread ===>>>>>" + future.get(2, TimeUnit.SECONDS));
System.out.println("Finished!");
}
catch (InterruptedException e)
{
System.out.println("Thread got Interrupted Exception ==============================>>>>>>>>>>>>>>>>>>>>>>>>>");
//e.printStackTrace();
}
catch (ExecutionException e)
{
System.out.println("Thread got Execution Exception ==============================>>>>>>>>>>>>>>>>>>>>>>>>>");
}
catch (TimeoutException e)
{
System.out.println("Thread got TimedOut Exception ==============================>>>>>>>>>>>>>>>>>>>>>>>>>");
future.cancel(true);
}
threadExecutor.shutdownNow();
}
}
Código da Classe de Chamada:
===================================================================
package com.test;
import java.util.concurrent.Callable;
public class PrintCallableTask implements Callable<String> {
private int sleepTime;
private String threadName;
public PrintCallableTask(String name)
{
threadName = name;
sleepTime = 100000;
}
@Override
public String call() throws Exception {
try {
System.out.printf("%s going to sleep for %d milliseconds.\n", threadName, sleepTime);
int i = 0;
while (i < 100000)
{
System.out.println(i++);
}
Thread.sleep(sleepTime); // put thread to sleep
System.out.printf("%s is in middle of execution \n", threadName);
} catch (InterruptedException exception) {
exception.printStackTrace();
}
System.out.printf("%s done sleeping\n", threadName);
return "success";
}
}