Java线程池的使用方法
本篇内容主要讲解“Java线程池的使用方法”,感兴趣的朋友不妨来看看。本文介绍的方法操作简单快捷,实用性强。下面就让小编来带大家学习“Java线程池的使用方法”吧!
在子洲等地区,都构建了全面的区域性战略布局,加强发展的系统性、市场前瞻性、产品创新能力,以专注、极致的服务理念,为客户提供成都网站设计、网站制作、外贸营销网站建设 网站设计制作按需规划网站,公司网站建设,企业网站建设,成都品牌网站建设,成都营销网站建设,外贸营销网站建设,子洲网站建设费用合理。
在任务与执行策略之间的隐形耦合
依赖任务
使用线程封闭机制的任务
对相应时间敏感的任务
使用ThreadLocal的任务
在线程池中,如果任务依赖于其他任务,那么可能产生死锁。
程序清单8-1 在单线程中任务发生死锁
public class ThreadDeadLock { Executor executor = Executors.newSingleThreadExecutor(); public class RenderPageTask implements Callable{ @Override public String call() throws Exception { Future header, footer; header = executor.execute(new LoadFileTask("header.html")); footer = executor.execute(new LoadFileTask("footer.html")); String page = renderBody(); //将发生死锁 -- 由于任务在等待子任务的结果 return header.get() + page + footer.get(); } } }
每当提交一个有依赖性的Executor任务时,要清楚地知道可能会出现线程"饥饿"死锁,因此需要在代码或配置Executor的配置文件中记录线程池的大小限制或配置限制。
除了在线程池大小上的显示限制外,还可能由于其他资源上的约束而存在一些隐式限制。如果应用程序使用一个包含10个连接的JDBC连接池,并且每个任务需要一个数据库连接,那么线程池就好像只有10个线程,因为当超过10个任务时,新的任务需要等待其他任务释放连接。
运行时间较长的任务
设置线程池的大小
配置ThreadPoolExecutor
ThreadPoolExecutor是线程池的真正实现,它构造方法提供了一系列参数来配置线程池。
public ThreadPoolExecutor (int corePoolSize, int maximumPoolSize, long keepAliveTime, TimeUnit unit, BlockingQueueworkQueue, ThreadFactory threadFactory) {...} public ThreadPoolExecutor(int corePoolSize, int maximumPoolSize, long keepAliveTime, TimeUnit unit, BlockingQueue workQueue, ThreadFactory threadFactory, RejectedExecutionHander hander) {...}
corePoolSize--线程池的核心线程数,默认情况下,核心线程会在线程池中一直存活,即使他们处于限制状态。如果将ThreadPoolExecutor的allowCoreThreadTimeOut属性
设置为true,那么闲置的线程核心线程在等待新任务到来时会有超时策略,这个时间间隔由keepAliveTime所指定,当等待时间超出keepAliveTime所指定的时长后,核心线程就会被终止。
maximumPoolSize--线程池所能容纳的最大线程数,当活动线程数达到这个数值后,后续的新任务将会被阻塞。
keepAliveTime--非核心线程闲置的超时时长,超过这个时长,非核心线程就会被回收。当ThreadPoolExecutor的属性allowCoreThreadTimeOut值为true时,keepAliveTime也作用于核心现程。
unit--用于指定keepAliveTime时间参数的单位,这是一个枚举,常用的有TimeOut.MILLISECONDS(毫秒)、TimeOut.SECONDS(秒)以及TimeOut.MINUTES(分钟)等。
workQueue--线程池中的任务队列,通过线程池的executor方法提交的Runnable对象会存储在这个参数中。
threadFactory--线程工厂,为线程池提供创建新线程的功能。ThreadFactory是一个接口,它只有一个方法:Thread newThread(Runnable r);
hander--不常用就不做介绍了。
ThreadPoolExecutor执行任务时大致遵循如下规则:
1 如果线程池中的线程数未达到核心数量,那么会直接启动一个核心线程来执行任务。
2 如果线程池中的线程数已达到或者超过核心数量,那么任务会被插入到任务队列中排队等待执行。
3 如果在步骤2中无法将任务插入到任务队列中,这往往是由于任务队列已满,这个时候如果线程数量未达到线程规定的最大值,那么会立刻启动一个非核心线程来执行任务。
4 如果步骤3中线程数量已经达到线程池规定的最大值,那么就拒绝执行任务,ThreadPoolExecutor会调用RejectedExecutionHander的rejectedExecution方法来通知调用者。
到此,相信大家对“Java线程池的使用方法”有了更深的了解,不妨来实际操作一番吧!这里是创新互联网站,更多相关内容可以进入相关频道进行查询,关注我们,继续学习!
网页名称:Java线程池的使用方法
标题网址:http://pwwzsj.com/article/jppjid.html