创建多线程的线程池的使用

一、为什么使用线程池

• 线程池主要解决2个方面的问题：
• 提升性能
• 在执行大量异步任务时，由于减少了任务执行的开销而明显提升性能。并且在执行一系列任务集合时，线程池提供了一种限制并管理资源（包括线程在内）的一种方法。
• 按我的理解，线程池能够重用之前的线程，甚至可以预创建线程，这就在实际任务执行时减少了创建线程的开销，进而提升性能。
• 线程池维护了一些基本的统计信息：例如已完成的任务数

import cn.hutool.core.lang.Console;
import org.apache.commons.lang3.StringUtils;
import java.util.concurrent.LinkedBlockingQueue;
import java.util.concurrent.ThreadPoolExecutor;
import java.util.concurrent.TimeUnit;

public class MyThreadTest {
    /***
     * corePoolSize：核心线程池的线程数量
     * maximumPoolSize：最大的线程池线程数量
     * keepAliveTime：线程活动保持时间，线程池的工作线程空闲后，保持存活的时间。
     * unit：线程活动保持时间的单位。
     * workQueue：指定任务队列所使用的阻塞队列
     * corePoolSize和maximumPoolSize都在指定线程池中的线程数量
     *
     * 首先会判断核心线程池里是否有线程可执行，有空闲线程则创建一个线程来执行任务。
     * 当核心线程池里已经没有线程可执行的时候，此时将任务丢到任务队列中去。
     * 如果任务队列（有界）也已经满了的话，但运行的线程数小于最大线程池的数量的时候，此时将会新建一个线程用于执行任务，但如果运行的线程数已经达到最大线程池的数量的时候，此时将无法创建线程执行任务。
     */
    ThreadPoolExecutor poolExecutor = new ThreadPoolExecutor(10, 150, 2, TimeUnit.SECONDS, new LinkedBlockingQueue<>(20));

    public static void main(String[] args) {
        MyThreadTest myThreadTest = new MyThreadTest();
        myThreadTest.test(100);
    }

    public void test(int size) {
        for (int i = 0; i < size; i++) {
            poolExecutor.execute(new DemoTask(i));
        }
        poolExecutor.shutdown();
    }

    class DemoTask implements Runnable {

        private int taskNum;

        public DemoTask(int taskNum) {
            this.taskNum = taskNum;
        }

        @Override
        public void run() {
            Console.log(StringUtils.center("正在执行" + taskNum, 20, "="));
            System.out.println(taskNum + " 被执行,线程名:" + Thread.currentThread().getName());
            Console.log(StringUtils.center("执行完毕" + taskNum, 20, "="));
        }
    }
}