ThreadPool：线程池-创新互联

1、定义

缓存一定线程数量的区域。

2、作用

复用、管理线程，避免新建线程/销毁线程消耗CPU资源。

3、核心参数

参数　　作用

corePoolSize(核心线程数)　　核心线程会一直存活

maximumPoolSize(大线程数)　　活动线程达到大线程数，后续新任务会阻塞

keepAliveTime(闲置线程超时时长)　　非核心线程闲置超过该时长将被回收(设置作用于核心线程threadPoolExecutor.allowCoreThreadTimeOut(true))

unit(keepAliveTime 单位)　　如：TimeUnit.MILLISECONDS, TimeUnit.SECONDS

workQueue(任务队列)　　存放 execute() 提交的 Runnable 对象

threadFactory(线程工厂)　　为线程池创建线程，Thread newThread(Runnable r)

4、工作流程

5、常用线程池

类型　　线程类型　　线程数量　　特点　　场景

定长线程池(FixedThreadPool)　　核心线程　　固定　　1、核心线程空闲不会回收。2、所有线程处于活动状态，新的任务将处于等待状态，直到有线程空闲。3、任务队列无大小限制。4、堆积的任务可能占用大内存　　控制线程大并发数

定时线程池(ScheduledThreadPool)　　核心、非核心线程　　核心:固定，非核心:无限制　　1、非核心线程闲置时会被回收。2、非核心线程无限制可能创建非常多线程。　　执行定时/ 周期性任务

可缓存线程池(CachedThreadPool)　　非核心　　无限制　　1、优先使用闲置线程处理任务。2、线程大小无限制。3、60 秒 回收闲置线程。4、非核心线程无限制可能创建非常多线程。　　执行数量多、耗时少的任务

单线程线程池(SingleThreadExecutor)　　核心线程　　1个　　1、任务顺序执行。2、不需要处理线程同步。3、堆积的任务可能占用大内存　　单线程

6、具体使用

public class ExecutorDemo {

public static void main(String[] args) {

createThreadPoolExecutor();

createFixedThreadPool();

createScheduledThreadPool();

createCachedThreadPool();

createSingleThreadExecutor();

}

private static final int CPU_COUNT = Runtime.getRuntime().availableProcessors();

private static final int CORE_POOL_SIZE = Math.max(2, Math.min(CPU_COUNT - 1, 4));

private static final int MAXIMUM_POOL_SIZE = CPU_COUNT * 2 + 1;

private static final int KEEP_ALIVE_SECONDS = 30;

private static final BlockingQueue sPoolWorkQueue =

new LinkedBlockingQueue(128);

private static final ThreadFactory sThreadFactory = new ThreadFactory() {

private final AtomicInteger mCount = new AtomicInteger(1);

@Override

public Thread newThread(Runnable r) {

return new Thread(r, "AsyncTask #" + mCount.getAndIncrement());

}

};

public static void createThreadPoolExecutor() {

// 1.创建自定义线程池

ThreadPoolExecutor threadPoolExecutor = new ThreadPoolExecutor(

CORE_POOL_SIZE,

MAXIMUM_POOL_SIZE,

KEEP_ALIVE_SECONDS,

TimeUnit.SECONDS,

sPoolWorkQueue,

sThreadFactory);

threadPoolExecutor.allowCoreThreadTimeOut(true);

// 2.创建任务

Runnable task = new Runnable() {

@Override

public void run() {

System.out.println("自定义线程池-任务执行");

}

};

// 3.通过线程池执行任务

threadPoolExecutor.execute(task);

// 4.关闭线程池

threadPoolExecutor.shutdown();

}

public static void createFixedThreadPool() {

// 1.创建定长线程池

// public static ExecutorService newFixedThreadPool(int var0) {

// return new ThreadPoolExecutor(var0, var0, 0L, TimeUnit.MILLISECONDS, new LinkedBlockingQueue());

// }

ExecutorService fixedThreadPool = Executors.newFixedThreadPool(3);

// 2.创建任务

Runnable task = new Runnable() {

@Override

public void run() {

System.out.println("定长线程池-任务执行");

}

};

// 3.通过线程池执行任务

fixedThreadPool.execute(task);

// 4.关闭线程池

fixedThreadPool.shutdown();

}

public static void createScheduledThreadPool() {

// 1.创建定时线程池

// public ScheduledThreadPoolExecutor(int var1) {

// super(var1, 2147483647, 0L, TimeUnit.NANOSECONDS, new ScheduledThreadPoolExecutor.DelayedWorkQueue());

// }　无锡妇科医院排行 http://www.0510bhyy.com/

ScheduledExecutorService scheduledThreadPool = Executors.newScheduledThreadPool(3);

// 2.创建任务

Runnable task = new Runnable() {

@Override

public void run() {

System.out.println("定时线程池-任务执行");

}

};

// 3.通过线程池执行任务,execute 立即执行，schedule 延迟1s执行,scheduleAtFixedRate 延迟1s执行之后每隔2秒执行

// scheduledThreadPool.execute(task);

scheduledThreadPool.schedule(task, 1000L, TimeUnit.MILLISECONDS);

// scheduledThreadPool.scheduleAtFixedRate(task,1000L,2000L, TimeUnit.MILLISECONDS);

// 4.关闭线程池

scheduledThreadPool.shutdown();

}

public static void createCachedThreadPool() {

// 1.创建可缓存线程池

// public static ExecutorService newCachedThreadPool() {

// return new ThreadPoolExecutor(0, 2147483647, 60L, TimeUnit.SECONDS, new SynchronousQueue());

// }

ExecutorService cachedThreadPool = Executors.newCachedThreadPool();

// 2.创建任务

Runnable task = new Runnable() {

@Override

public void run() {

System.out.println("可缓存线程池-任务执行");

}

};

// 3.通过线程池执行任务

cachedThreadPool.execute(task);

// 4.关闭线程池

cachedThreadPool.shutdown();

}

public static void createSingleThreadExecutor() {

// 1.创建单线程线程池

// public static ExecutorService newSingleThreadExecutor() {

// return new Executors.FinalizableDelegatedExecutorService(new ThreadPoolExecutor(1, 1, 0L, TimeUnit.MILLISECONDS, new LinkedBlockingQueue()));

// }

ExecutorService singleThreadExecutor = Executors.newSingleThreadExecutor();

// 2.创建任务

Runnable task = new Runnable() {

@Override

public void run() {

System.out.println("单线程线程池-任务执行");

}

};

// 3.通过线程池执行任务

singleThreadExecutor.execute(task);

// 4.关闭线程池

singleThreadExecutor.shutdown();

}

}

另外有需要云服务器可以了解下创新互联scvps.cn，海内外云服务器15元起步，三天无理由+7*72小时售后在线，公司持有idc许可证，提供“云服务器、裸金属服务器、高防服务器、香港服务器、美国服务器、虚拟主机、免备案服务器”等云主机租用服务以及企业上云的综合解决方案，具有“安全稳定、简单易用、服务可用性高、性价比高”等特点与优势，专为企业上云打造定制，能够满足用户丰富、多元化的应用场景需求。