ThreadLocal vs 线程池 — 别再搞混了

// 1. 定义:通常静态 final
private static final ThreadLocal<User> currentUser = new ThreadLocal<>();

// 2. 拦截器里设置(请求进来)
currentUser.set(new User("张三"));

// 3. 业务代码任何地方取
User user = currentUser.get();  // 拿到 "张三",不用层层传参

// 4. 用完必须清理!否则泄漏
currentUser.remove();

// 线程池:管理一组线程,任务来了复用
ThreadPoolExecutor pool = new ThreadPoolExecutor(
    2,                              // 核心线程数
    4,                              // 最大线程数
    60, TimeUnit.SECONDS,          // 空闲存活
    new ArrayBlockingQueue<>(100), // 任务队列
    new ThreadPoolExecutor.CallerRunsPolicy()  // 拒绝策略
);

// 提交任务:线程池分配一个线程去跑
pool.submit(() -> {
    sendEmail(userId);  // 异步发邮件
});

你的问题是?

├── "多个线程操作同一份数据,怕冲突"
│   ├── 要加锁同步? → synchronized / Lock
│   └── 能每线程一份数据? → ✅ ThreadLocal(隔离,不加锁)
│
├── "任务太多,想并发执行 + 控制并发数"
│   └── → ✅ 线程池(复用线程,排队,限流)
│
├── "想在请求链路里随处取当前用户"
│   └── → ✅ ThreadLocal(线程上下文)
│
└── "两者都需要(异步任务里要取当前用户)"
    └── → ✅ 一起用(但小心泄漏!见第 6 节)

// ========== ThreadLocal:存当前用户(隔离) ==========
public class UserContext {
    private static final ThreadLocal<User> holder = new ThreadLocal<>();

    public static void set(User u) { holder.set(u); }
    public static User get() { return holder.get(); }
    public static void clear() { holder.remove(); }
}

// 拦截器:请求进来存,结束清
public class AuthFilter implements Filter {
    public void doFilter(...) {
        User user = parseUser(request);
        UserContext.set(user);      // ← ThreadLocal 存
        try {
            chain.doFilter(...);    // 业务里 UserContext.get() 取
        } finally {
            UserContext.clear();     // ← 必须清!否则泄漏
        }
    }
}


// ========== 线程池:异步发邮件(复用) ==========
public class EmailService {
    // 线程池:管理发邮件的线程
    private static final ExecutorService pool =
        new ThreadPoolExecutor(
            2, 4, 60, TimeUnit.SECONDS,
            new LinkedBlockingQueue<>(100));

    public void sendAsync(Long userId) {
        pool.submit(() -> {           // ← 线程池提交任务
            sendEmail(userId);
        });
    }
}

ThreadLocal<User> ctx = new ThreadLocal<>();

try {
    ctx.set(currentUser);
    // ... 业务逻辑,随处 ctx.get() 取
    doBusiness();
} finally {
    ctx.remove();   // ← 关键!线程池环境绝对不能漏
}

// ❌ 问题:提交到线程池,异步线程拿不到主线程的 ThreadLocal
User user = UserContext.get();  // 主线程能拿到
pool.submit(() -> {
    // 异步线程里 UserContext.get() 是 null!不同线程
    log(UserContext.get());  // null
});

// ✅ 方案1:手动传参(最简单)
User user = UserContext.get();
pool.submit(() -> task(user));  // 把 user 显式传进去

// ✅ 方案2:TransmittableThreadLocal(阿里 TTL,线程池透传)
// 用 TTL 替代 ThreadLocal,submit 用 TtlExecutors.getTtlExecutor 包装
// 异步线程自动继承主线程的值