欢迎您访问程序员文章站本站旨在为大家提供分享程序员计算机编程知识!
您现在的位置是: 首页  >  IT编程

线程池:三大方法、7大参数、4种拒绝策略

程序员文章站 2022-04-19 13:30:03
池化技术:程序运行就是资源的占用,池化就是优化资源利用,线程池,连接池啥的,创建销毁很耗费时间空间,所以就提前准备好资源,你来那就行,用完换回来。减少资源消耗,速度提升,还有或就是方便管理,线程复用,就像sqlsession一样,查出数据存着,可控制最大并发三大方法:(不建议使用)//三大方法public class ThreeMathed { public static void main(String[] args) { ExecutorService pool= E...

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

//三大方法
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