多线程、线程池篇-蒲公英云

多线程、线程池篇

一、初始化线程的四种方式

1.继承Thread

2.实现Runable接口

3.实现Callable接口+FutureTask(可以拿到返回结果，可以处理异常)

方式1和方式2：主进程无法获取线程的运算结果，不合适当前场景。

方式3：主进程可以获取线程的运算结果，但是不利于服务器种的线程资源，会导致服务器资源耗尽

方式4：正常开发通过线程池的方式初始化线程，因为通过线程池性能稳定，也可以获取执行结果，并捕获异常。

Executors.newFiexedThreadPool(3);
//或者
new ThreadPoolExecutor(corePoolSize, maximumPoolSize, keepAliveTime, TimeUnit unit, workQueue, threadFactory,

二、线程池的七大参数

1、核心线程数：线程池中一直保持的可运行的核心线程。

2、最大线程数：线程池中允许的最大线程数。

3.空闲线程时间：当线程池中的线程数量超过核心线程数，且这些线程空闲时间超过空闲线程时间，多余的线程就会销毁，直到线程池中的线程数量不大于核心线程数。

4.时间单位：线程的时间单位

5.阻塞队列：用来存储等待执行的任务线程，如果当前对线程的需求超过了核心线程数大小，就会放在这里等待空闲线程执行。

6.工厂：创建线程的工厂

7.拒绝策略：当队列满，且线程达到最大线程后，还有任务进来，线程池就会使用拒绝策略。

三、线程池的运行流程：

例子：一个线程池核心线程数10个，最大线程数20个，阻塞队列50个、共100个并发任务进来如何分配：

10个核心线程直接执行，然后50个任务进入阻塞队列，因为最大线程是20，最大线程-核心线程=10个线程，还可以安排10个线程，最大可以安排70个线程执行（阻塞队列数+最大线程数），剩余30个任务进入拒绝策略处理，不执行。


import java.util.concurrent.*;
public class ThreadPoolExample {
    public static void main(String[] args) {
        // 创建一个线程池，core 10:max20,queue:50
        ThreadPoolExecutor executor = new ThreadPoolExecutor(
            10, // 核心线程数为 10
            20, // 最大线程数为 20
            0L, TimeUnit.MILLISECONDS, // keep-alive time 为 0 毫秒，即非核心线程空闲立即回收
            new LinkedBlockingQueue<>(50)); // 阻塞队列大小为 50
        // 设置拒绝策略为抛出异常
        executor.setRejectedExecutionHandler(new ThreadPoolExecutor.AbortPolicy());
        try {
            // 开始提交 100 个任务
            for (int i = 0; i < 100; i++) {
                executor.execute(() -> {
                    try {
                        Thread.sleep(100);
                        System.out.println("Task executed by thread " + Thread.currentThread().getId());
                    } catch (InterruptedException e) {
                        e.printStackTrace();
                    }
                });
            }
        } finally {
            // 关闭线程池
            executor.shutdown();
        }
    }
}