JAVA 使用ThreadPoolExecutor线程池，如何判断线程池中所有线程都跑完了

可以通过`ThreadPoolExecutor`的`getActiveCount()`方法来获取线程池中正在执行任务的线程数量，如果该方法返回值为0，即表示线程池中所有线程都已经执行完毕。

另外，可以通过`ThreadPoolExecutor`的`getCompletedTaskCount()`方法来获取线程池中已经完成的任务数量，如果该方法返回值等于线程池中总的任务数，即表示线程池中所有任务都已经执行完毕。

需要注意的是，如果线程池中设置了`allowCoreThreadTimeOut(true)`，即核心线程也可以被回收的话，那么在所有任务执行完毕后，可能会有一些核心线程还在等待新的任务，此时需要使用`ThreadPoolExecutor`的`awaitTermination()`方法来等待所有线程都结束。

相关问题

java自定义ThreadPoolExecutor线程池

在Java中，我们可以通过自定义ThreadPoolExecutor类来创建自己的线程池。ThreadPoolExecutor类是ExecutorService接口的一个实现，它提供了一个灵活的线程池管理机制。

要自定义ThreadPoolExecutor线程池，我们需要使用ThreadPoolExecutor类的构造函数来创建一个实例，并设置一些参数来配置线程池的行为。下面是一个示例代码：

import java.util.concurrent.BlockingQueue;
import java.util.concurrent.LinkedBlockingQueue;
import java.util.concurrent.ThreadPoolExecutor;
import java.util.concurrent.TimeUnit;

public class CustomThreadPoolExecutor {
    public static void main(String[] args) {
        // 创建一个阻塞队列，用于存放待执行的任务
        BlockingQueue<Runnable> queue = new LinkedBlockingQueue<>(10);
        
        // 创建自定义的线程池
        ThreadPoolExecutor executor = new ThreadPoolExecutor(
            5, // 核心线程数
            10, // 最大线程数
            1, // 空闲线程存活时间
            TimeUnit.MINUTES, // 时间单位
            queue // 阻塞队列
        );

        // 添加任务到线程池中
        for (int i = 0; i < 20; i++) {
            executor.execute(() -> {
                System.out.println("执行任务");
            });
        }

        // 关闭线程池
        executor.shutdown();
    }
}

在上面的示例代码中，我们使用了一个LinkedBlockingQueue作为阻塞队列来存放待执行的任务。然后，我们创建了一个ThreadPoolExecutor实例，并设置了核心线程数为5，最大线程数为10，空闲线程存活时间为1分钟。接下来，我们通过execute方法向线程池提交了20个任务。

最后，记得要调用executor.shutdown()方法来关闭线程池，以确保所有任务执行完毕并释放资源。

通过自定义ThreadPoolExecutor类，我们可以根据实际需求来设置线程池的参数，并且可以根据需要灵活地处理提交的任务。

java 使用ThreadPoolExecutor 线程池，子线程调用FeignClient时，Token丢失

这个问题可能是因为FeignClient在调用时会新开一个线程，但是这个线程没有继承主线程的ThreadLocal变量，所以导致了Token丢失的问题。解决这个问题可以尝试在ThreadPoolExecutor的execute方法中，手动将主线程的ThreadLocal变量传递给子线程，代码示例如下：

ThreadPoolExecutor executor = new ThreadPoolExecutor(corePoolSize, maximumPoolSize, keepAliveTime, unit, workQueue);
executor.execute(() -> {
    // 在子线程中调用FeignClient时，手动将主线程的ThreadLocal变量传递给子线程
    RequestContext context = RequestContext.getCurrentContext();
    RequestAttributes requestAttributes = RequestContextHolder.currentRequestAttributes();
    context.set("requestAttributes", requestAttributes);
    try {
        // 调用FeignClient
        // ...
    } finally {
        context.unset();
    }
});

在FeignClient中，可以通过RequestContextHolder获取ThreadLocal变量，示例如下：

@Component
public class MyFeignClientInterceptor implements RequestInterceptor {

    @Override
    public void apply(RequestTemplate requestTemplate) {
        RequestContext context = RequestContext.getCurrentContext();
        RequestAttributes requestAttributes = (RequestAttributes) context.get("requestAttributes");
        ServletRequestAttributes attributes = (ServletRequestAttributes) requestAttributes;
        HttpServletRequest request = attributes.getRequest();

        // 获取Token等信息
        // ...
        
        // 将Token等信息添加到header中
        requestTemplate.header("Authorization", token);
    }
}

这样就可以在子线程中正确地获取到主线程中的ThreadLocal变量，避免了Token丢失的问题。