一、四种线程池创建的方式
Java通过Executors提供四种线程池,分别为:
newCachedThreadPool 创建一个可缓存线程池,如果线程池长度超过处理需要,可灵活回收空闲线程,若无可回收,则新建线程。
newFixedThreadPool 创建一个定长线程池,可控制线程最大并发数,超出的线程会在队列中等待。
newScheduledThreadPool 创建一个定长线程池,支持定时及周期性任务执行。
newSingleThreadExecutor 创建一个单线程化的线程池,它只会用唯一的工作线程来执行任务,保证所有任务按照指定顺序(FIFO, LIFO, 优先级)执行。
查看源码发现,在创建这四种线程池都是通过ThreadPoolExecutor来实现的。
二、实战
简单不说了,网上都有,页面底部也有推荐的资料。
接下来,直接使用Spring中的线程池来展示,大多的项目中都会用到Spring,所以就可能会使用ThreadPoolTaskExecutor。
1.首先,配置线程池的属性
itom.parseAsyncTaskExecutor.corePoolSize=10 itom.parseAsyncTaskExecutor.maxPoolSize=100 itom.parseAsyncTaskExecutor.queueCapacity=200 itom.parseAsyncTaskExecutor.keepAliveSeconds=300 itom.parseAsyncTaskExecutor.rejectedExecutionHandler=java.util.concurrent.ThreadPoolExecutor$CallerRunsPolicy
2.applicationContext-itom.xml中配置Bean
<?xml version="1.0" encoding="UTF-8"?> <beans xmlns="http://www.springframework.org/schema/beans" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd" default-lazy-init="true" default-autowire="byName"> <!--线程池--> <bean id="threadPoolTaskExecutor" class="org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor"> <!--核心线程数,默认为1 --> <property name="corePoolSize" value="${itom.parseAsyncTaskExecutor.corePoolSize}" /> <!--最大线程数,默认为Integer.MAX_VALUE --> <property name="maxPoolSize" value="${itom.parseAsyncTaskExecutor.maxPoolSize}" /> <!--队列最大长度,一般需要设置值>=notifyScheduledMainExecutor.maxNum;默认为Integer.MAX_VALUE --> <property name="queueCapacity" value="${itom.parseAsyncTaskExecutor.queueCapacity}" /> <!--线程池维护线程所允许的空闲时间,默认为60s --> <property name="keepAliveSeconds" value="${itom.parseAsyncTaskExecutor.keepAliveSeconds}" /> <!--线程池对拒绝任务(无线程可用)的处理策略,目前只支持AbortPolicy、CallerRunsPolicy;默认为后者 --> <property name="rejectedExecutionHandler"> <!--AbortPolicy:直接抛出java.util.concurrent.RejectedExecutionException异常 --> <!--CallerRunsPolicy:主线程直接执行该任务,执行完之后尝试添加下一个任务到线程池中,可以有效降低向线程池内添加任务的速度 --> <!--DiscardOldestPolicy:抛弃旧的任务、暂不支持;会导致被丢弃的任务无法再次被执行 --> <!--DiscardPolicy:抛弃当前任务、暂不支持;会导致被丢弃的任务无法再次被执行 --> <bean class="${itom.parseAsyncTaskExecutor.rejectedExecutionHandler}" /> </property> </bean> </beans>
3.在实现的service中直接使用
@Service("itomService") public class ItomServiceImpl implements ItomService{ @Autowired private LoginService loginService; @Autowired private ThreadPoolTaskExecutor threadPoolTaskExecutor; @Override public void calc(final String userId, final String sourceCode) { threadPoolTaskExecutor.execute(new Runnable() { @Override public void run() { ... } }); } }
4.在类里面直接使用:(根据需要,定制相应的线程池)
private static final ThreadPoolExecutor pool = new ThreadPoolExecutor(10, 10, 60L, TimeUnit.SECONDS, new LinkedBlockingQueue<Runnable>(100), new ThreadPoolExecutor.AbortPolicy());
四种线程池的使用:
http://cuisuqiang.iteye.com/blog/2019372
关于线程池框架写得比较全的:
http://blog.csdn.net/tuke_tuke/article/details/51353925
ThreadPoolExecutor的介绍(属性的信息):
http://blog.xiaohansong.com/2016/07/12/java-executor/
其他:
(Executor、ExecutorService、ThreadPoolExecutor的区别)
http://blog.csdn.net/linghu_java/article/details/17123057
相关推荐
JAVA使用线程池查询大批量数据
主要给大家介绍了关于java线程池使用后到底要不要关闭的相关资料,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧
简单的线程池程序+中文文档 包结构: com.tangkai.threadpool --SimpleThread.java 工作线程 --TestThreadPool.java 程序入口 --ThreadPoolManager.java 线程池管理类
Java线程池使用说明Java线程池使用说明Java线程池使用说明
java 线程池 完整 源码 java 线程池 完整 源码
2.然后根据提示运行java命令执行示例程序,观看线程池的运行结果 目标:Java中多线程技术是一个难点,但是也是一个核心技术。因为Java本身就是一个多线程语言。本人目前在给46班讲授Swing的网络编程--使用Swing来...
Java版线程池实现
Reference: 《创建Java线程池》[1],《Java线程:新特征-线程池》[2], 《Java线程池学习》[3],《线程池ThreadPoolExecutor使用简介》[4],《Java5中的线程池实例讲解》[5],《ThreadPoolExecutor使用和思考》[6] ...
java 线程池 java 线程池 java 线程池 java 线程池
Java concurrency线程池之线程池原理(一)_动力节点Java学院整理,动力节点口口相传的Java黄埔军校
JAVA实现的线程池,可以直接在正规大型项目中套用。如果有不懂的,可以问我,QQ:452242541,加时注明csdn
java多线程,对多线程,线程池进行封装,方便使用
Java实现通用线程池
java线程池封装j
本文旨在使用Java语言编写一个通用的线程池。当需要使用线程池处理事务时,只需按照指定规范封装好事务处理对象,然后用已有的线程池对象去自动选择空 闲线程自动调用事务处理对象即可。并实现线程池的动态修改...
自定义实现Java线程池,学习大师设计思想,瞻仰大神笔法
执行一个异步任务你还只是如下new Thread吗?是不是太low 了一点? 我这里有四种线程池的案例轻松让你理解和使用线程池。
java线程池知识、
是一个java在进行socket编程时,关于线程池的介绍,有代码和例子
讲述了java线程池的优点,参数,6种线程池的使用场景,线程池用到的handler,线程任务的提交方式等等。