import java.util.concurrent.ArrayBlockingQueue;
import java.util.concurrent.BlockingQueue;
import java.util.concurrent.ThreadPoolExecutor;
import java.util.concurrent.TimeUnit;
import java.util.concurrent.ThreadPoolExecutor.AbortPolicy;
public class ThreadPoolTest {
//线程池维护线程的最少数量
private static final int COREPOOLSIZE = 2;
//线程池维护线程的最大数量
private static final int MAXINUMPOOLSIZE = 5;
//线程池维护线程所允许的空闲时间
private static final long KEEPALIVETIME = 4;
//线程池维护线程所允许的空闲时间的单位
private static final TimeUnit UNIT = TimeUnit.SECONDS;
//线程池所使用的缓冲队列,这里队列大小为3
private static final BlockingQueue<Runnable> WORKQUEUE = new ArrayBlockingQueue<Runnable>(3);
//线程池对拒绝任务的处理策略:AbortPolicy为抛出异常;CallerRunsPolicy为重试添加当前的任务,他会自动重复调用execute()方法;DiscardOldestPolicy为抛弃旧的任务,DiscardPolicy为抛弃当前的任务
private static final AbortPolicy HANDLER = new ThreadPoolExecutor.AbortPolicy();
public static void main(String[] args) {
// TODO 初始化线程池
ThreadPoolExecutor threadPool = new ThreadPoolExecutor(COREPOOLSIZE, MAXINUMPOOLSIZE, KEEPALIVETIME, UNIT, WORKQUEUE, HANDLER);
for (int i = 1; i < 11; i++) {
String task = "task@"+i;
System.out.println("put->"+task);
//一个任务通过 execute(Runnable)方法被添加到线程池,任务就是一个 Runnable类型的对象,任务的执行方法就是 Runnable类型对象的run()方法
//处理任务的优先级为:核心线程corePoolSize、任务队列workQueue、最大线程maximumPoolSize,如果三者都满了,使用handler处理被拒绝的任务
//设此时线程池中的数量为currentPoolSize,若currentPoolSize>corePoolSize,则创建新的线程执行被添加的任务,
//当corePoolSize+workQueue>currentPoolSize>=corePoolSize,新增任务被放入缓冲队列,
//当maximumPoolSize>currentPoolSize>=corePoolSize+workQueue,建新线程来处理被添加的任务,
//当currentPoolSize>=maximumPoolSize,通过 handler所指定的策略来处理新添加的任务
//本例中可以同时可以被处理的任务最多为maximumPoolSize+WORKQUEUE=8个,其中最多5个在线程中正在处理,3个在缓冲队列中等待被处理
//当currentPoolSize>corePoolSize时,如果某线程空闲时间超过keepAliveTime,线程将被终止。这样,线程池可以动态的调整池中的线程数
threadPool.execute(new ThreadPoolTask(task));
try {
Thread.sleep(1000);
} catch (InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
threadPool.shutdown();//关闭主线程,但线程池会继续运行,直到所有任务执行完才会停止。若不调用该方法线程池会一直保持下去,以便随时添加新的任务
}
}
import java.io.Serializable;
public class ThreadPoolTask implements Runnable,Serializable{
private static final long serialVersionUID = -8568367025140842876L;
private Object threadPoolTaskData;
private static int produceTaskSleepTime = 10000;
public ThreadPoolTask(Object threadPoolTaskData) {
super();
this.threadPoolTaskData = threadPoolTaskData;
}
public void run() {
// TODO Auto-generated method stub
System.out.println("start..."+threadPoolTaskData);
try {
//模拟线程正在执行任务
Thread.sleep(produceTaskSleepTime);
} catch (InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
System.out.println("stop..."+threadPoolTaskData);
threadPoolTaskData = null;
}
public Object getTask(){
return this.threadPoolTaskData;
}
}
输出:
put->task@1
start...task@1
put->task@2
start...task@2
put->task@3
put->task@4
put->task@5
put->task@6
start...task@6
put->task@7
start...task@7
put->task@8
start...task@8
put->task@9
Exception in thread "main" java.util.concurrent.RejectedExecutionException
at java.util.concurrent.ThreadPoolExecutor$AbortPolicy.rejectedExecution(ThreadPoolExecutor.java:1760)
at java.util.concurrent.ThreadPoolExecutor.reject(ThreadPoolExecutor.java:767)
at java.util.concurrent.ThreadPoolExecutor.execute(ThreadPoolExecutor.java:658)
at ThreadPoolTest.main(ThreadPoolTest.java:36)
stop...task@1
start...task@3
stop...task@2
start...task@4
stop...task@6
start...task@5
stop...task@7
stop...task@8
stop...task@3
stop...task@4
stop...task@5
但是线程池本身的线程永远不会中止
分享到:
相关推荐
本案例详细介绍了JDK自带线程池,与spring的线程池相比,其更好,希望对大家有帮助
而线程池不允许使用Executors去创建,而要通过ThreadPoolExecutor方式,这一方面是由于jdk中Executor框架虽然提供了如newFixedThreadPool()、newSingleThreadExecutor()、newCachedThreadPool()等创建线程池的方法,...
在最近做的一个项目中,需要大量的使用到多线程和线程池,下面就java自带的线程池和大家一起分享
JDK1.5线程池源码及详细注释 深入研究java线程原理
JDK1[1].5中的线程池(ThreadPoolExecutor)使用简介
JDK1.5的线程池讲解,示例代码,很精辟~
利用jdk自带算法实现的AES加解密工具类及Base64编解码工具类、 文件操作工具类、aes扩展无限制权限策略文件等。 在jdk1.7环境亲测通过。
Reference: 《创建Java线程池》[1],《Java线程:新特征-线程池》[2], 《Java线程池学习》[3],《线程池ThreadPoolExecutor使用简介》[4],《Java5中的线程池实例讲解》[5],《ThreadPoolExecutor使用和思考》[6] ...
JDK1.5中的线程池(ThreadPoolExecutor)使用简介
资源很不错
介绍一个通用多线程服务模块。是利用jdk线程池,多线程并行处理多任务,以提高执行效率。
JDK自带xml解析器dom+sax JDK自带xml解析器dom+sax JDK自带xml解析器dom+sax
主要介绍了JDK线程池和Spring线程池的使用实例解析,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下
通过这个实例可以简单了解webservice.实现的方法是用jdk自带的功能。 此份资料是在blogjava中找到的,供入门学习使用。
corePoolSize: 线程池维护线程的最少数量 maximumPoolSize:线程池维护线程的最大数量 keepAliveTime: 线程池维护线程所允许的空闲时间 unit: 线程池维护线程所允许的空闲时间的单位 workQueue: 线程池所使用的...
JDK自带调试工具doc JDK自带调试工具doc JDK自带调试工具doc
使用jdk自带的jar工具打jar包 采用命令行的方式 方便 快捷
JDK自带的jarsigner签名工具帮助文档,指导大家用自带的JDK通过控制台签名apk;主要指令如下:jarsigner -verbose -keystore [您的签名存放路径]-signedjar [签名后的文件名] [未签名的文件名] [您的证书名称]
详细介绍了jdk自带的工具的使用方法等 JDK自带工具分析 1 1、工具分类概括: 2 1.1、基本工具 2 1.2、安全工具 3 1.3、Java国际化工具 3 1.4、远程方法调用工具 3 1.5、Java IDL and RMI-IIOP 工具 3 1.6、Java 部署...
JDK1.5中的线程池(java.util.concurrent.ThreadPoolExecutor)使用