线程池的实现

佚名 6年前 (2019-04-15) 随笔 2039人围观抢沙发百度已收录

线程创建倾向

如果运行的线程的小于corePoolSize，当请求来时，创建新线程。

如果运行corePoolSize或多于，当请求来时，排队。

SRE实战互联网时代守护先锋，助力企业售后服务体系运筹帷幄！一键直达领取阿里云限量特价优惠。

如果请求不能进行排队，且小于maximumPoolSize创建新线程，请求会被拒绝。

不要使用Executors.newXXXThreadPool()快捷方法创建线程池，因为这种方式会使用无界的任务队列，为避免OOM。

1、创建线程池

 1 package com.learn.threadTest;
 2 
 3 
 4 import java.util.concurrent.ArrayBlockingQueue;
 5 import java.util.concurrent.ExecutorService;
 6 import java.util.concurrent.TimeUnit;
 7 import java.util.concurrent.ThreadPoolExecutor;
 8 
 9 public class DefineThreadPoolFactory {
10     
11 
12     private final static int corePoolSize = 5;//活跃线程数
13     private final static int maximumPoolSize = 20;//最大线程数
14     private final static long keepAliveTime = 0;//临时线程活跃时长
15     
16     public static ExecutorService threadPoolFactory () {
17         ExecutorService executorService = new ThreadPoolExecutor(corePoolSize,maximumPoolSize,keepAliveTime,TimeUnit.SECONDS,new ArrayBlockingQueue<>(128));
18         return executorService;
19     }
20     public static void main(String[] arg0) {
21         threadPoolFactory().submit(new Runnable() {
22             @Override
23             public void run() {
24                 Thread.currentThread().setName("虾来了");
25                 System.out.println("获取到线程资源,线程名{"+Thread.currentThread().getName()+"}");
26                 System.out.println("获取到线程资源,线程名{"+Thread.currentThread().getId()+"}");
27             }
28         });
29     }
30 }