文档章节

Java关于线程池的使用

乐在克里特
 乐在克里特
发布于 2017/02/24 13:45
字数 856
阅读 38
收藏 1

一、四种线程池创建的方式

Java通过Executors提供四种线程池,分别为:
newCachedThreadPool 创建一个可缓存线程池,如果线程池长度超过处理需要,可灵活回收空闲线程,若无可回收,则新建线程。
newFixedThreadPool 创建一个定长线程池,可控制线程最大并发数,超出的线程会在队列中等待。
newScheduledThreadPool 创建一个定长线程池,支持定时及周期性任务执行。
newSingleThreadExecutor 创建一个单线程化的线程池,它只会用唯一的工作线程来执行任务,保证所有任务按照指定顺序(FIFO, LIFO, 优先级)执行。

 

查看源码发现,在创建这四种线程池都是通过ThreadPoolExecutor来实现的。

推荐:(摘取阿里技术规范)

线程池不允许使用 Executors 去创建,而是通过 ThreadPoolExecutor 的方式,
这样的处理方式让写的同学更加明确线程池的运行规则,规避资源耗尽的风险。
说明:Executors 各个方法的弊端:
1)newFixedThreadPool 和 newSingleThreadExecutor:
主要问题是堆积的请求处理队列可能会耗费非常大的内存,甚至 OOM。
2)newCachedThreadPool 和 newScheduledThreadPool:
主要问题是线程数最大数是 Integer.MAX_VALUE,可能会创建数量非常多的线程,甚至 OOM。
 

 

二、实战

简单不说了,网上都有,页面底部也有推荐的资料。

接下来,直接使用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

 

补充一片写到我认为是重点的博客:

http://gityuan.com/2016/01/16/thread-pool/

© 著作权归作者所有

共有 人打赏支持
乐在克里特
粉丝 15
博文 268
码字总数 394729
作品 0
杭州
程序员
JAVA多线程和并发基础面试问答

Java多线程面试问题 1. 进程和线程之间有什么不同? 一个进程是一个独立(self contained)的运行环境,它可以被看作一个程序或者一个应用。而线程是在进程中执行的一个任务。Java运行环境是一...

清风傲剑
2014/12/06
0
0
JAVA多线程和并发基础面试问答

原文链接 译文连接 作者:Pankaj 译者:郑旭东 校对:方腾飞 多线程和并发问题是Java技术面试中面试官比较喜欢问的问题之一。在这里,从面试的角度列出了大部分重要的问题,但是你仍然应该牢...

雷神雨石
2014/07/19
0
2
JAVA多线程和并发基础面试问答

多线程和并发问题是Java技术面试中面试官比较喜欢问的问题之一。在这里,从面试的角度列出了大部分重要的问题,但是你仍然应该牢固的掌握Java多线程基础知识来对应日后碰到的问题。(校对注:...

LCZ777
2014/05/26
0
0
JAVA多线程和并发基础面试问答

Java多线程面试问题 1. 进程和线程之间有什么不同? 一个进程是一个独立(self contained)的运行环境,它可以被看作一个程序或者一个应用。而线程是在进程中执行的一个任务。Java运行环境是一...

hanzhankang
2014/01/20
0
0
Java的JDBC数据库连接池实现方法

虽然J2EE程序员一般都有现成的应用服务器所带的JDBC数据库连接池,不过对于开发一般的Java Application、 Applet或者JSP、velocity时,我们可用的JDBC数据库连接池并不多,并且一般性能都不好...

lixun
2012/10/11
0
0

没有更多内容

加载失败,请刷新页面

加载更多

Sqoop 操作实例补充

导入指定字段和指定条件的行记录 # 指定导入的字段--columns <col,col,col…># 指定过滤条件--where <where clause># 设置切分的工作单元--split-by <column-name># 目标目录存在...

PeakFang-BOK
8分钟前
1
0
App store 侵权投诉

App Store Content Dispute 侵权投诉 https://www.apple.com/legal/internet-services/itunes/appstorenotices/#?lang=zh...

壹峰
11分钟前
0
0
教程:如何在window上安装Apache HTTP Server

Apache官网只提供 Apache HTTP Server 的源代码,不提供编译好的二进制文件。 不过我们还是可以从网络上找到其他人编译好的Apache HTTP Server。 首先,从 https://www.apachehaus.com/cgi-b...

Doxde
28分钟前
0
0
中国移动蔡谦:5G传输准备就绪

目前5G已成业界热议话题,在即将到来的万物互联时代,5G是非常关键的技术。且5G相比4G,业务场景多种多样,对5G承载网带来巨大挑战。5G传输,承载先行并不仅仅是一个口号。当前5G承载网的部署...

linux-tao
36分钟前
4
0
维护“修理权”,苹果使用专有软件工具来修复MacBook Pro和iMac Pro

根据上月发给苹果授权服务提供商的一份文件,苹果公司正在使用新的专有软件诊断工具来修复MacBook Pros和iMac Pros,如果不用专有软件工具来修复关键部件,将会导致“系统失效和修复不完整”...

linuxCool
今天
2
0

没有更多内容

加载失败,请刷新页面

加载更多

返回顶部
顶部