前言

• 多线程是每个程序员的噩梦,用得好可以提升效率很爽，用得不好就是埋汰的火葬场。
• 这里不深入介绍，主要是讲解一些标准用法，熟读唐诗三百首，不会作诗也会吟。
• 这里就介绍一下springboot中的多线程的使用，使用线程连接池去异步执行业务方法。
• 由于代码中包含详细注释,也为了保持文章的整洁性，我就不过多的做文字描述了。

VisiableThreadPoolTaskExecutor 编写

• new VisiableThreadPoolTaskExecutor() 方式创建线程池, 返回值是 Executor

点击查看代码

import lombok.extern.slf4j.Slf4j;
import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;
import org.springframework.util.concurrent.ListenableFuture;

import java.util.concurrent.Callable;
import java.util.concurrent.Future;
import java.util.concurrent.ThreadPoolExecutor;

/**
 * @author love ice
 * @create 2023-09-19 0:17
 */
@Slf4j
public class VisiableThreadPoolTaskExecutor extends ThreadPoolTaskExecutor {
    @Override
    public void execute(Runnable task){
        showThreadPoolInfo("execute一个参数的方法执行");
    }

    @Override
    public void execute(Runnable task, long startTimeout){
        showThreadPoolInfo("execute两个参数的方法执行");
    }

    @Override
    public Future<?> submit(Runnable task){
        showThreadPoolInfo("submit Runnable task 入参方法执行");
        return super.submit(task);
    }

    @Override
    public <T> Future<T> submit(Callable<T> task){
        showThreadPoolInfo("submit Callable<T> task 入参方法执行");
        return super.submit(task);
    }

    @Override
    public ListenableFuture<?> submitListenable(Runnable task){
        showThreadPoolInfo("submitListenable(Runnable task) 方法执行");
        return super.submitListenable(task);
    }

    @Override
    public <T>ListenableFuture<T> submitListenable(Callable<T> task){
        showThreadPoolInfo("submitListenable(Callable<T> task) 方法执行");
        return super.submitListenable(task);
    }

    private void showThreadPoolInfo(String prefix){
        ThreadPoolExecutor threadPoolExecutor = getThreadPoolExecutor();
        log.info("{}, {}, taskCount[{}], completedTaskCount[{}], activeCount[{}], queueSize[{}]",
                this.getThreadNamePrefix(), prefix, threadPoolExecutor.getTaskCount(),
                threadPoolExecutor.getCompletedTaskCount(), threadPoolExecutor.getActiveCount(),
                threadPoolExecutor.getQueue().size());
    }
}

ThreadExceptionLogHandler 编写

• 主要用于线程池出现异常时的捕获

点击查看代码

import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Component;

/**
 * @author love ice
 * @create 2023-09-19 0:13
 */
@Slf4j
@Component
public class ThreadExceptionLogHandler implements Thread.UncaughtExceptionHandler {

    @Override
    public void uncaughtException(Thread t, Throwable e) {
        log.error("[{}]线程池异常,异常信息为:{}",t.getName(),e.getMessage(),e);
    }
}

ExecutorConfig 编写

• 核心配置类

点击查看代码

import com.test.redis.Infrastructure.handler.ThreadExceptionLogHandler;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.scheduling.annotation.EnableAsync;
import java.util.concurrent.*;
import java.util.concurrent.atomic.AtomicInteger;

/**
 * 线程池配置
 *
 * @author love ice
 * @create 2023-09-19 0:09
 */
@Configuration
@EnableAsync
public class ExecutorConfig {
    @Value("${thread