future 取消任务测试

ExecutorService es = Executors.newCachedThreadPool();

Future<?>  future = es.submit(new Runnable() {

@Override

public void run() {

// TODO Auto-generated method stub

try{

Thread.sleep(300000l);

System.out.println("begin");

for(int i=0;i<100000;i++){

if(Thread.currentThread().isInterrupted()){

System.err.println("Interrupted");

break;

}

System.out.println(i);

}

System.out.println("finish");

}catch (InterruptedException e) {

e.printStackTrace();

}catch (Exception e) {

e.printStackTrace();

}

}

});

Thread.sleep(1*1000l);

future.cancel(true);

System.out.println("interupt is send");