1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40
| import java.util.concurrent.Callable;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.Future;
import java.util.concurrent.TimeUnit;
import java.util.concurrent.TimeoutException;
public class HelloWorld {
public static void main(String[] args) throws Exception {
ExecutorService executor = Executors.newSingleThreadExecutor();
for (int time =2; time < 15; time++){
System.out.println("timing: "+time);
Future<String> future = executor.submit(new Task());
try {
System.out.println("Debut "+new java.util.Date());
System.out.println(future.get(time, TimeUnit.SECONDS));
System.out.println("Fin "+new java.util.Date());
} catch (TimeoutException e) {
//future.cancel(true);
System.out.println("Annulee "+new java.util.Date());
}
future.get(); //wait termination
System.out.println("NEXT! ");
}
executor.shutdownNow();
}
}
class Task implements Callable<String> {
//@Override
public String call() throws Exception {
int max=20;
for(int i=0; i<max; i++){
System.out.println("Tic "+i);
TimeUnit.SECONDS.sleep(1);
}
return "Task terminee";
}
} |
Partager