|
关于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 (编辑:湖南网)
【声明】本站内容均来自网络,其相关言论仅代表作者个人观点,不代表本站立场。若无意侵犯到您的权利,请及时与联系站长删除相关内容!
|