在项目开发中,为了能够加快程序的处理速度,有时候我们会将问题分解成若干个并发执行的任务,并且创建线程池,所以可见线程池的作用有重要!那java线程池的最大线程数是多少?接下来我们就来给大家讲解一下这方面的内容。
java线程池的最大线程数没有过固定数量,可以成百上千。
java线程池拒绝策略是什么?
线程池中的线程已经用完了,无法继续为新任务服务,同时,等待队列也已经排满了,再也塞不下新任务了。这时候我们就需要拒绝策略机制合理的处理这个问题。
JDK 内置的拒绝策略如下:
1.AbortPolicy : 直接抛出异常,阻止系统正常运行。
2.CallerRunsPolicy : 只要线程池未关闭,该策略直接在调用者线程中,运行当前被丢弃的任务。显然这样做不会真的丢弃任务,但是,任务提交线程的性能极有可能会急剧下降。
3.DiscardPolicy : 该策略默默地丢弃无法处理的任务,不予任何处理。如果允许任务丢失,这是最好的一种方案。
4.DiscardOldestPolicy : 丢弃最老的一个请求,也就是即将被执行的一个任务,并尝试再次提交当前任务。
以上内置拒绝策略均实现了 RejectedExecutionHandler 接口,若以上策略仍无法满足实际需要,完全可以自己扩展 RejectedExecutionHandler 接口。
1.AbortPolicy(默认拒绝策略)
(也可以没有new ThreadPoolExecutor.AbortPolicy() 这个参数 ,隐式的默认拒绝策略)
import java.util.concurrent.LinkedBlockingQueue; import java.util.concurrent.ThreadPoolExecutor; import java.util.concurrent.TimeUnit; public class ThreadDemo58 { public static void main(String[] args) { // 创建线程池 ThreadPoolExecutor executor = new ThreadPoolExecutor( 5, 5, 0, TimeUnit.SECONDS, new LinkedBlockingQueue<>(5), new ThreadPoolExecutor.AbortPolicy()); for (int i = 0; i < 11; i++) { int finalI = i; executor.execute(new Runnable() { @Override public void run() { System.out.println("任务:" + finalI + ",线程名:" + Thread.currentThread().getName()); } }); } } }
2.CallerRunsPolicy(使用调用线程池的线程来执行任务 )
(即使用主线程来执行任务)
import java.util.concurrent.LinkedBlockingQueue; import java.util.concurrent.ThreadPoolExecutor; import java.util.concurrent.TimeUnit; public class ThreadDemo59 { public static void main(String[] args) throws InterruptedException { // 创建线程池 ThreadPoolExecutor executor = new ThreadPoolExecutor( 5, 5, 0, TimeUnit.SECONDS, new LinkedBlockingQueue<>(5), new ThreadPoolExecutor.CallerRunsPolicy()); for (int i = 0; i < 11; i++) { int finalI = i; executor.execute(new Runnable() { @Override public void run() { System.out.println("任务:" + finalI + ",线程名:" + Thread.currentThread().getName()); } }); // Thread.sleep(200); } } }
3. DiscardPolicy (忽略新任务)
import java.util.concurrent.LinkedBlockingQueue; import java.util.concurrent.ThreadPoolExecutor; import java.util.concurrent.TimeUnit; public class ThreadDemo59 { public static void main(String[] args) throws InterruptedException { // 创建线程池 ThreadPoolExecutor executor = new ThreadPoolExecutor( 5, 5, 0, TimeUnit.SECONDS, new LinkedBlockingQueue<>(5), new ThreadPoolExecutor.AbortPolicy()); for (int i = 0; i < 11; i++) { int finalI = i; executor.execute(new Runnable() { @Override public void run() { System.out.println("任务:" + finalI + ",线程名:" + Thread.currentThread().getName()); } }); } } }
4. DiscardOldestPolicy(忽略老任务)
(老任务指第一个进入阻塞队列里的)
import java.util.concurrent.LinkedBlockingQueue; import java.util.concurrent.ThreadPoolExecutor; import java.util.concurrent.TimeUnit; public class ThreadDemo59 { public static void main(String[] args) throws InterruptedException { // 创建线程池 ThreadPoolExecutor executor = new ThreadPoolExecutor( 5, 5, 0, TimeUnit.SECONDS, new LinkedBlockingQueue<>(5), new ThreadPoolExecutor.DiscardOldestPolicy()); for (int i = 0; i < 11; i++) { int finalI = i; executor.execute(new Runnable() { @Override public void run() { System.out.println("任务:" + finalI + ",线程名:" + Thread.currentThread().getName()); } }); } } }
1.5 自定义拒绝策略
import java.util.concurrent.LinkedBlockingQueue; import java.util.concurrent.RejectedExecutionHandler; import java.util.concurrent.ThreadPoolExecutor; import java.util.concurrent.TimeUnit; public class ThreadDemo60 { public static void main(String[] args) throws InterruptedException { // 创建线程池 ThreadPoolExecutor executor = new ThreadPoolExecutor( 5, 5, 0, TimeUnit.SECONDS, new LinkedBlockingQueue<>(5), new RejectedExecutionHandler() { @Override public void rejectedExecution(Runnable r, ThreadPoolExecutor executor) { // 自定义拒绝策略 System.out.println("执行了自定义拒绝策略"); } }); for (int i = 0; i < 11; i++) { int finalI = i; executor.execute(new Runnable() { @Override public void run() { System.out.println("任务:" + finalI + ",线程名:" + Thread.currentThread().getName()); } }); } } }
Java线程池的拒绝策略就是以上这几种,其中AbortPolicy为默认拒绝策略,当然我们也可以自定义拒绝策略,这就要根据实际情况去看了!最后大家如果想要了解更多java入门知识,敬请关注奇Q工具网。
推荐阅读: