java线程池工作队列饱和策略代码示例_Java教程

线程池（thread pool）是并行执行任务收集的实用工具。随着 cpu 引入适合于应用程序并行化的多核体系结构，线程池的作用正日益显现。通过 threadpoolexecutor类及其他辅助类，java 5 引入了这一框架，作为新的并发支持部分。

threadpoolexecutor框架灵活且功能强大，它支持特定于用户的配置并提供了相关的挂钩（hook）和饱和策略来处理满队列

java线程池会将提交的任务先置于工作队列中，在从工作队列中获取(synchronousqueue直接由生产者提交给工作线程)。那么工作队列就有两种实现策略：无界队列和有界队列。无界队列不存在饱和的问题，但是其问题是当请求持续高负载的话，任务会无脑的加入工作队列，那么很可能导致内存等资源溢出或者耗尽。而有界队列不会带来高负载导致的内存耗尽的问题，但是有引发工作队列已满情况下，新提交的任务如何管理的难题，这就是线程池工作队列饱和策略要解决的问题。

饱和策略分为：abort 策略, callerruns 策略,discard策略，discardolds策略。

为了更好的理解，我编写一个小的例子。

									package concurrency.pool;

									import java.util.concurrent.linkedblockingdeque;

									import java.util.concurrent.rejectedexecutionhandler;

									import java.util.concurrent.threadpoolexecutor;

									import java.util.concurrent.timeunit;

									public class saturationpolicy {

									    /**

									   * 线程池工作队列已满时，在不同饱和策略下表现

									   * @param handler 线程池工作队列饱和策略

									   */

									    public static void policy(rejectedexecutionhandler handler){

									        //基本线程2个，最大线程数为3，工作队列容量为5

									        threadpoolexecutor exec = new threadpoolexecutor(2,3,0l, timeunit.milliseconds,new linkedblockingdeque<>(5));

									        if (handler != null){

									            exec.setrejectedexecutionhandler(handler);

									            //设置饱和策略

									        }

									        for (int i = 0; i < 10; i++) {

									            exec.submit(new task());

									            //提交任务

									        }

									        exec.shutdown();

									    }

									    public static void main(string[] args) {

									        //    policy(new threadpoolexecutor.abortpolicy());

									        //    policy((new threadpoolexecutor.callerrunspolicy()));

									        //    policy(new threadpoolexecutor.discardpolicy());

									        //    policy(new threadpoolexecutor.discardoldestpolicy());

									    }

									    //自定义任务

									    static class task implements runnable {

									        private static int count = 0;

									        private int id = 0;

									        //任务标识

									        public task() {

									            id = ++count;

									        }

									        @override

									            public void run() {

									            try {

									                timeunit.seconds.sleep(3);

									                //休眠3秒

									            }

									            catch (interruptedexception e) {

									                system.err.println("线程被中断" + e.getmessage());

									            }

									            system.out.println(" 任务：" + id + "\t 工作线程: "+ thread.currentthread().getname() + " 执行完毕");

									        }

									    }

									}