package com.bjsxt.height.concurrent018; import java.util.concurrent.ArrayBlockingQueue; import java.util.concurrent.ExecutorService; import java.util.concurrent.Executors; import java.util.concurrent.LinkedBlockingQueue; import java.util.concurrent.ThreadPoolExecutor; import java.util.concurrent.ThreadPoolExecutor.DiscardOldestPolicy; import java.util.concurrent.TimeUnit; import java.util.concurrent.ThreadPoolExecutor.CallerRunsPolicy; public class UseThreadPoolExecutor1 { public static void main(String[] args) { /** * 在使用有界队列时,若有新的任务需要执行,如果线程池实际线程数小于corePoolSize,则优先创建线程, * 若大于corePoolSize,则会将任务加入队列, * 若队列已满,则在总线程数不大于maximumPoolSize的前提下,创建新的线程, * 若线程数大于maximumPoolSize,则执行拒绝策略。或其他自定义方式。 * * 如果是无界队列线程池有多少,一次并发运行多少。无界队列要排队,具体参考上面。 * 无界队列(第二个参数MaxSize ,设置无效,并发处理量 看corepoolsize大小): LinkedBlockingQueue 与有界队列相比,除非系统内容耗尽,否则不存在失败情况 当有新任务到来,corepoolsize后,就不会继续增加,若后续仍有新任务加入,而 没有空闲的线程,则任务直接进入队列等待。若任务创建和处理的速度差异很大,无界 队列保存快速增长,指导资源耗尽。 JDK拒绝策略: AbortPolicy :直接抛出异常,系统正常工作。 CallerRunSPolicy:只要线程池没有关闭,在调用者线程中,运行当前被丢弃的任务。 DiscarOldestPolicy:丢弃最老的一个请求,尝试再次提交当前任务。 DiscardPolicy:丢弃无法处理的人为奴,不给任何处理。 */ ThreadPoolExecutor pool = new ThreadPoolExecutor( 1, //coreSize 5, //MaxSize 60, //60 TimeUnit.SECONDS, new ArrayBlockingQueue<Runnable>(2) //指定一种队列 (有界队列) //new LinkedBlockingQueue<Runnable>() //, new MyRejected() , new DiscardOldestPolicy()//指定进不去队列后的 处理办法。 ); //ExecutorService pool = Executors.newFixedThreadPool(10); MyTask mt1 = new MyTask(1, "任务1"); MyTask mt2 = new MyTask(2, "任务2"); MyTask mt3 = new MyTask(3, "任务3"); MyTask mt4 = new MyTask(4, "任务4"); MyTask mt5 = new MyTask(5, "任务5"); MyTask mt6 = new MyTask(6, "任务6"); pool.execute(mt1); pool.execute(mt2); pool.execute(mt3); pool.execute(mt4); pool.execute(mt5); pool.execute(mt6); pool.shutdown();//线程执行完后才关闭。 } }
package com.bjsxt.height.concurrent018; import java.net.HttpURLConnection; import java.util.concurrent.RejectedExecutionHandler; import java.util.concurrent.ThreadPoolExecutor; public class MyRejected implements RejectedExecutionHandler{ public MyRejected(){ } @Override public void rejectedExecution(Runnable r, ThreadPoolExecutor executor) { System.out.println("自定义处理.."); System.out.println("当前被拒绝任务为:" + r.toString()); } }
package com.bjsxt.height.concurrent018; public class MyTask implements Runnable { private int taskId; private String taskName; public MyTask(int taskId, String taskName){ this.taskId = taskId; this.taskName = taskName; } public int getTaskId() { return taskId; } public void setTaskId(int taskId) { this.taskId = taskId; } public String getTaskName() { return taskName; } public void setTaskName(String taskName) { this.taskName = taskName; } @Override public void run() { try { System.out.println("run taskId =" + this.taskId); Thread.sleep(5*1000); //System.out.println("end taskId =" + this.taskId); } catch (InterruptedException e) { e.printStackTrace(); } } public String toString(){ return Integer.toString(this.taskId); } }
相关推荐
主要介绍了Java线程池的拒绝策略实现详解,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下
线程池示例(包含自定义拒绝策略),演示了如何创建一个线程池,以及添加到队列的过程,先添加到工作线程,然后是缓存队列,最后是创建临时线程
线程池详解:线程池七大核心参数、线程池工作原理、线程池的创建方式、线程池的拒绝策略、如何合理分配线程池大小 文件内容包括pdf文件和思维导图
4,线程池拒绝策略有哪些? 5,AQS的使用场景和使用方式? 6,有哪些线程安全的map?有哪些线程安全的队列? listedbockingque的同步原理? 7,垃圾回收器g1,cms介绍一下。 8,介绍一下,索引的隔离级别? 9,...
资源回答:为什么需要线程池?常见的线程池有哪几个种?线程池的核心参数有哪几个?线程池的核心原理?线程池的拒绝策略。属于高频面试题
handler:表示当拒绝处理任务时的策略,就是上面提及的reject操作;有以下四种取值: ThreadPoolExecutor.AbortPolicy:丢弃任务并抛出RejectedExecutionException异常。(默认handle) ThreadPoolExecutor....
Java并发编程常见知识点源码集锦,涉及到对象锁,Executors多任务线程框架,线程池等... ConcurrentLinkedQueue、DelayQueue示例、自定义的线程拒绝策略、自定义线程池(使用有界队列)、自定义线程池(使用无界队列)。。。
线程池创建的时候,如果不指定拒绝策略就默认是AbortPolicy策略。当然,你也可以自己实现RejectedExecutionHandler接口,比如将任务存在数据库或者缓存中,这样就数据库或者缓存中获取到被拒绝掉的任务了。
corePoolSize: 线程池维护线程的最少数量 maximumPoolSize:线程池维护线程的最大数量 keepAliveTime: 线程池维护线程所允许的空闲时间 unit: 线程池维护线程所允许的空闲...handler: 线程池对拒绝任务的处理策略
1.媲美java线程池框架,整套源码资源,使用Intellij Idea开发工具,JDK1.8以上 2.带有测试代码 ...4.任务队列、拒绝策略 5.BasicThreadPool.java、LinkedRunnableQueue.java、RunnableDenyException.java
本文将详细介绍线程池的基本参数、每一种线程池类型的特性,以及常见的拒绝策略。同时,我们将提供完整的源代码和注释,帮助您更好地理解和应用线程池。 Spring Boot中的线程池为开发者提供了强大的并发支持。通过...
1.定制化线程池实现高并发数据处理。2.线程池实现了拒绝策略,自动扩缩容,线程安全,管道队列,高并发数据处理等。3.完全按照Java封装,继承,多态的特性进行开发,实现了多个接口,用户可自行扩展。
自己编写的线程池。具备的功能:自动扩容线程池大小,闲时回收线程。能够实现拒绝策略,
这篇文章结合Doug Lea大神在JDK1.5提供的JCU包,分别从线程池大小参数的设置、工作线程的创建、空闲线程的回收、阻塞队列的使用、任务拒绝策略、线程池Hook等方面来了解线程池的使用,其中涉及到一些细节包括不同...
线程池原理-ThreadPoolExecutor源码解析 1.构造方法及参数 2.阻塞对列: BlockingQueue 3.线程工厂: DefaultThreadFactory 4.拒绝策略: RejectedExecutionHandler 5.执行线程 Executor
JUC是什么 线程 进程 / 线程 线程状态 wait / sleep 并发 / 并行 Lock 使用Lock锁 可重入锁 公平锁 / 非公平锁 Synchronized / Lock ...线程池四种拒绝策略 ForkJoin 异步回调 Volatile 指令重排 JMM
自定义线程线程池 如果当前线程池中的线程数目小于corePoolSize,则每来一个任务,就会...如果当前线程池中的线程数目达到maximumPoolSize,则会采取任务拒绝策略进行处理; 如果线程池中的线程数量大于 corePoolSize时
分为三部分: 核心线程池 线程池 队列 拒绝策略 主要流程: 1.判断核心线程池是否已满, 如果不是, 则创建线程执行任务 2.如果核心线程池满了, 判断队列是否满了, 如果队列没满, 将任务放在队列中 3.如果队列满了, ...
同步队列基于数组的有界队列无容量的同步队列有容量的有界队列拒绝执行策略任务入队列策略、线程创建策略– parking to wait for <0x000000
简介 Executors类的基本用法 2.1 创建线程池 2.2 提交任务 2.3 关闭线程池 线程池的分类 3.1 FixedThreadPool 3.2 CachedThreadPool ...4.6 拒绝策略 线程池的最佳实践 线程池的异常处理 线程池的优势和适用场景