java线程池攻略

╰半橙微兮° 2022-11-25 11:42 109阅读 0赞

多线程运行时间，系统不断的启动和关闭新线程，成本非常高，会过渡消耗系统资源，以及过渡切换线程的危险，从而可能导致系统资源的崩溃。这时，线程池就是最好的选择了。

我们首先看看线程池的构造方法

public ThreadPoolExecutor(int corePoolSize,int maximumPoolSize,long keepAliveTime,TimeUnit unit,
            BlockingQueue<Runnable> workQueue,ThreadFactory threadFactory,RejectedExecutionHandler handler);

1.corePoolSize：预创建线程，起始有几个线程

2.maximumPoolSize：线程池最大容量

3.keepAliveTime：默认大于起始线程数 就执行，到期则会终止。也可以通过allowCoreThreadTimeOut(boolean)来开启

4.unit：

TimeUnit.DAYS;               //天
    TimeUnit.HOURS;             //小时
    TimeUnit.MINUTES;           //分钟
    TimeUnit.SECONDS;           //秒
    TimeUnit.MILLISECONDS;      //毫秒
    TimeUnit.MICROSECONDS;      //微妙
    TimeUnit.NANOSECONDS;       //纳秒

5.workQueue：一个阻塞队列，用来存储等待执行的任务

ArrayBlockingQueue;
    LinkedBlockingQueue;
    SynchronousQueue;

一般使用LinkedBlockingQueue和Synchronous

6.threadFactory：线程工厂，主要用来创建线程；

7.handler：表示当拒绝处理任务时的策略，有以下四种取值：

当线程池的任务缓存队列已满并且线程池中的线程数目达到maximumPoolSize时，如果还有任务到来就会采取任务拒绝策略，

ThreadPoolExecutor.AbortPolicy:丢弃任务并抛出RejectedExecutionException异常。 
    ThreadPoolExecutor.DiscardPolicy：也是丢弃任务，但是不抛出异常。 
    ThreadPoolExecutor.DiscardOldestPolicy：丢弃队列最前面的任务，然后重新尝试执行任务（重复此过程）
    ThreadPoolExecutor.CallerRunsPolicy：由调用线程处理该任务

举例：

public static void main(String[] args) {
         BlockingQueue<Runnable> queue = new ArrayBlockingQueue<>(10);
         ThreadFactory factory = r -> new Thread(r, "test-thread-pool");
         ThreadPoolExecutor executor = new ThreadPoolExecutor(5, 5,
                0L, TimeUnit.SECONDS, queue, factory, new ThreadPoolExecutor.CallerRunsPolicy());
    
       for (int i = 0; i < 1000; i++) {
           executor.submit(() -> {
       try {
        System.out.println(Thread.currentThread().getName() + ":执行任务");
        Thread.sleep(1000);
      } catch (InterruptedException e) {
        e.printStackTrace();
          }
        });
      }
     }

![20200808155723793.png][]

[20200808155723793.png]: /images/20221124/60297244cf504a7fb1bf5189f381957a.png