乘风原创程序

  • 线程池:三大方法、7大参数、4种拒绝策略
  • 2020/7/7 14:28:34
  • 池化技术:
    程序运行就是资源的占用,池化就是优化资源利用,线程池,连接池啥的,创建销毁很耗费时间空间,所以就提前准备好资源,你来那就行,用完换回来。
    减少资源消耗,速度提升,还有或就是方便管理,线程复用,就像sqlsession一样,查出数据存着,可控制最大并发
    三大方法:(不建议使用)
    在这里插入图片描述

    //三大方法
    public class ThreeMathed {
        public static void main(String[] args) {
            ExecutorService pool= Executors.newSingleThreadExecutor();//单个线程
    //        ExecutorService pool= Executors.newFixedThreadPool(5);//自己设置固定的
    //        ExecutorService pool= Executors.newCachedThreadPool();//可伸缩,遇强则强
            try {
                for (int i = 0; i < 100; i++) {
                    //使用线程池后,创建线程
                    pool.execute(()->{
                        System.out.println(Thread.currentThread().getName()+"--Ok");
                    });
                }
            } catch (Exception e) {
                e.printStackTrace();
            } finally {
                //关闭线程池
                pool.shutdown();
            }
        }
    }
    

    7大参数

    
    /**
     * 四大拒绝策略
     * 1.new ThreadPoolExecutor.AbortPolicy()//银行满了,还有人来,直接报错java.util.concurrent.RejectedExecutionException
     * 2.new ThreadPoolExecutor.CallerRunsPolicy()//队列满了,哪来的回哪去(main)
     * 3.new ThreadPoolExecutor.DiscardPolicy()//队列加最大容量满了,直接丢掉任务,不会抛出异常
     * 4.new ThreadPoolExecutor.DiscardOldestPolicy()//队列加最大容量满了,尝试和最早的竞争,不会抛出异常
     */
    public class SevenParams {
        public static void main(String[] args) {
            //自定义线程池,七大参数
            ExecutorService threadPool =new ThreadPoolExecutor(
                    2,//核心容量
                    5,//最大容量
                    3,//阻塞时间
                    TimeUnit.SECONDS,//时间单位
                    new LinkedBlockingDeque<>(3),//阻塞队列,就是银行等候区
                    Executors.defaultThreadFactory(),
                    new ThreadPoolExecutor.CallerRunsPolicy()//队列满了,哪来的回哪去(main)
            );
    
            try {
                //最大承载=核心容量+阻塞队列
                //超过
                for (int i = 0; i < 9; i++) {
                    threadPool.execute(()->{
                        System.out.println(Thread.currentThread().getName()+"ok");
                    });
                }
            } catch (Exception e) {
                e.printStackTrace();
            } finally {
                //记得关闭线程池
                threadPool.shutdown();
            }
        }
    }
    

    4种拒绝策略,就是最大承载=核心容量+阻塞队列,满了的策略
    /**

    • new ThreadPoolExecutor.AbortPolicy() // 银行满了,还有人进来,不处理这个人的,抛出异常
    • new ThreadPoolExecutor.CallerRunsPolicy() // 哪来的去哪里!
    • new ThreadPoolExecutor.DiscardPolicy() //队列满了,丢掉任务,不会抛出异常!
    • new ThreadPoolExecutor.DiscardOldestPolicy() //队列满了,尝试去和最早的竞争,也不会抛出异常!
      */

    本文地址:https://blog.csdn.net/code_mzh/article/details/107143975