关于ThreadPoolExecutor ,前面第3节已经详细叙述。ScheduledThreadPoolExecutor 也是ExecutorService接口的实现类,可以在给定的延迟后运行命令,或者定期执行命令。ScheduledThreadPoolExecutor 比 Timer 更灵活,功能更强大。
4.4 Future与FutureTask
上面的示例中使用 execute() 方法提交任务,,用于提交不需要返回值的任务。如果我们需要获取执行任务之后的返回值,可以使用submit()方法。
示例代码:
- public static void main(String[] args) throws InterruptedException, ExecutionException {
- //新建一个线程池
- ExecutorService executor = Executors.newCachedThreadPool();
- List<Future> futureList = new Vector<>();
- //在其它线程中执行100次下列方法
- for (int i = 0; i < 100; i++) {
- futureList.add(executor.submit(new Callable<String>() {
- @Override
- public String call() throws Exception {
- return Thread.currentThread().getName()+" "+System.currentTimeMillis()+" ";
- }
- }));
- }
- for (int i = 0;i<futureList.size();i++){
- Object o = futureList.get(i).get();
- System.out.println(o.toString()+i);
- }
- executor.shutdown();
- }
运行结果:
- ...
- pool-1-thread-11 1537872778612 96
- pool-1-thread-11 1537872778613 97
- pool-1-thread-10 1537872778613 98
- pool-1-thread-10 1537872778613 99
到这里,就不得不提Future接口与FutureTask实现类,它们代表异步计算的结果。
- Future<T> submit(Callable<T> task)
- Future<?> submit(Runnable task);
- Future<T> submit(Runnable task, T result);
当我们submit()提交后,会返回一个Future对象,到JDK1.8,返回的实际是FutureTask实现类。submit() 方法支持 Runnable 或 Callable 类型的参数。Runnable 接口 和Callable 接口的区别就是 Runnable 不会返回结果,Callable 会返回结果。
主线程可以执行 futureTask.get() 方法来阻塞当前线程直到任务执行完成,任务完成后返回任务执行的结果。
futureTask.get(long timeout, TimeUnit unit) 方法则会阻塞当前线程一段时间立即返回,这时候有可能任务没有执行完。
主线程也可以执行 futureTask.cancel(boolean mayInterruptIfRunning) 来取消此任务的执行。
futureTask.isCancelled方法表示任务是否被取消成功,如果在任务正常完成前被取消成功,则返回 true。
futureTask.isDone方法表示任务是否已经完成,若任务完成,则返回true。 【编辑推荐】 - Java 8中用法优雅的Stream,性能也"优雅"吗?
- Web性能优化:理解及使用JavaScript缓存
- Java开发者希望未来使用Python和Go
- 将来会是Python、Java、Golang三足鼎立的局面吗?
- 几行JavaScript代码构建计算机视觉程序,这里有6个js框架
【责任编辑:武晓燕 TEL:(010)68476606】
点赞 0
(编辑:ASP站长网)
|