Callable、Future和FutureTask使用说明

王朝学院·作者佚名  2016-08-27
窄屏简体版  字體: 小  |  中  |  大  |  超大  

普通的创建线程,一种是直接继承Thread,另外一种就是实现Runnable接口。但是这两种都无法在执行完任务之后获取执行结果,Callable、Future就提供了这样的便利。

Future的方法说明:

boolean cancel(boolean mayInterruptIfRunning);

cancel方法用来取消任务,如果取消任务成功则返回true,如果取消任务失败则返回false。

参数mayInterruptIfRunning表示是否允许取消正在执行却没有执行完毕的任务,如果设置true,则表示可以取消正在执行过程中的任务。如果任务已经完成,则无论mayInterruptIfRunning为true还是false,此方法肯定返回false,即如果取消已经完成的任务会返回false;如果任务正在执行,若mayInterruptIfRunning设置为true,则返回true,若mayInterruptIfRunning设置为false,则返回false;如果任务还没有执行,则无论mayInterruptIfRunning为true还是false,肯定返回true。boolean isCancelled();

isCancelled方法表示任务是否被取消成功,如果在任务正常完成前被取消成功,则返回 true。

boolean isDone();

isDone方法表示任务是否已经完成,若任务完成,则返回true;

V get() throws InterruptedException, ExecutionException;

get()方法用来获取执行结果,这个方法会产生阻塞,会一直等到任务执行完毕才返回;

V get(long timeout, TimeUnit unit) throws InterruptedException, ExecutionException, TimeoutException;

get(long timeout, TimeUnit unit)用来获取执行结果,如果在指定时间内,还没获取到结果,就直接返回null。

而FutureTask即可以作为Runnable又可以作为Future,这样就既可以用ExecutorService的execute执行任务,也可以用ExecutorService的submit提交任务。

例子1:

Callable、Future实现子线程执行任务,并返回结果,主线程等待子线程结果在进行其他逻辑。(多个子线程并行执行任务,主线程做合并处理参见CompletionService用法)

importjava.util.concurrent.Callable;

importjava.util.concurrent.ExecutionException;

importjava.util.concurrent.ExecutorService;

importjava.util.concurrent.Executors;

importjava.util.concurrent.Future;

publicclassCallableAndFuture1 {

publicstaticvoidmain(String[] args) {

ExecutorService service = Executors.newSingleThreadExecutor();

Future<Integer> future = service.submit(newCallable<Integer>() {

@Override

publicInteger call()throwsException {

System.out.PRintln("子线程"+ Thread.currentThread().getName() +"在进行计算");

Thread.sleep(3000);

intsum = 0;

for(inti = 0; i < 100; i++) {

sum += i;

}

returnsum;

}

});

System.out.println("主线程"+ Thread.currentThread().getName() +"在执行任务");

try{

System.out.println("子线程运行结果"+ future.get());

}catch(InterruptedException e) {

e.printStackTrace();

}catch(ExecutionException e) {

e.printStackTrace();

}

System.out.println("所有任务执行完毕");

}

}

 
 
免责声明:本文为网络用户发布,其观点仅代表作者个人观点,与本站无关,本站仅提供信息存储服务。文中陈述内容未经本站证实,其真实性、完整性、及时性本站不作任何保证或承诺,请读者仅作参考,并请自行核实相关内容。
 
© 2005- 王朝網路 版權所有 導航