java线程池的基本使用
2015-08-15 09:52
597 查看
四种线程池
在Executors中提供了四种线程池:
newCachedThreadPool可缓存线程池,对于每个线程,如果有空闲线程可用,立即让它执行,如果没有,则创建一个新线程
newFixedThreadPool具有固定大小的线程池,如果任务数大于空闲的线程数,则把它们放进队列中等待
newSingleThreadPool大小为1的线程池,任务一个接着一个完成
newScheduledThreadPool定长线程池,可控制线程最大并发数,支持定时及周期性任务执行,用来代替Timer
基本方法
在上文http://segmentfault.com/a/1190000003091174 中说到了callable不能直接被Thread运行,但却能被线程池运行,ExecutorService提供了几种方法运行一个任务:
Future submit(Callable task);
Future submit(Runnable task, T result);
Future
控制一组任务
ExecutorService提供了
invokeAny和
invokeAll方法,它们是批量执行的最常用形式,它们执行任务collection,然后等待至少一个,或全部任务完成
/** 执行给定的任务,当所有任务完成时,返回保持任务状态和结果的 Future 列表。返回列表的所有元素的 Future.isDone() 为 true。 注意,可以正常地或通过抛出异常来终止已完成任务。 **/ <T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> tasks) throws InterruptedException /** 执行给定的任务,如果其中一个任务的结果。一旦正常或异常返回后,则取消尚未完成的任务。 **/ <T> T invokeAny(Collection<? extends Callable<T>> tasks) throws InterruptedException, ExecutionException
invokeAny方法提交所有任务到一个
Callable对象的集合中,并且返回某个已经完成了的任务的结果,返回的任务是不确定的。
invokeAll方法则返回所有任务的结果,可以这样来对结果进行处理:
List<Callable<T>> tasks=... List<Future<T>> results = executor.invokeAll(tasks); for(Future<T> result : results){ process(result.get()); } ...
这样处理的一个弊端是,如果第一个任务花费了很长时间,则不得不等待。在某些情况下,可能只需要一个任务出了结果就可以中止所有任务,这样就得不偿失。将结果按照可获得的顺序保存起来可能更好,这时需要用到
ExecutorCompletionService来进行排列:
ExecutorCompletionService service = new ExecutorCompletionService(executor); for(Callable<T> task:tasks){ service.submit(task); } for(int i = 0;i < task.size();i++){ process(service.take().get()); } ...
其中,
take()方法会移除下一个已经完成的结果(
Future),如果没有可用结果则阻塞
使用小结
在使用线程池时,大多应该按照以下步骤:调用
Executors类中的静态方法
newCachedThreadPool或
newFixedThreadPool创建线程池;
调用
submit提交
Runnable或
Callable任务;
如果想取消一个任务,或者提交了
Callable对象,那就要保存好返回的
Future对象;
当不再提交任务时,调用
shutdown
相关文章推荐
- java对世界各个时区(TimeZone)的通用转换处理方法(转载)
- java-注解annotation
- java-模拟tomcat服务器
- java-用HttpURLConnection发送Http请求.
- java-WEB中的监听器Lisener
- Android IPC进程间通讯机制
- Android Native 绘图方法
- Android java 与 javascript互访(相互调用)的方法例子
- 介绍一款信息管理系统的开源框架---jeecg
- 聚类算法之kmeans算法java版本
- java实现 PageRank算法
- PropertyChangeListener简单理解
- 插入排序
- 冒泡排序
- 堆排序
- 快速排序
- 二叉查找树
- [原创]java局域网聊天系统