在CompletableFuture中使用TTL，主线程执行完成，但CompletableFuture未完成，是否可以可以释放上下文，主线程释放上下文后，CompletableFuture是否还能拿到TTL的值

[kginglam]

1.这是我包装的Executor

public class CustomThreadPoolTaskExecutor extends ThreadPoolTaskExecutor {



    @Override
    public void execute(Runnable runnable) {
        Runnable ttlRunnable = TtlRunnable.get(runnable);
        super.execute(ttlRunnable);
    }

    @Override
    public <T> Future<T> submit(Callable<T> task) {
        Callable ttlCallable = TtlCallable.get(task);
        return super.submit(ttlCallable);
    }

    @Override
    public Future<?> submit(Runnable task) {
        Runnable ttlRunnable = TtlRunnable.get(task);
        return super.submit(ttlRunnable);
    }

    @Override
    public ListenableFuture<?> submitListenable(Runnable task) {
        Runnable ttlRunnable = TtlRunnable.get(task);
        return super.submitListenable(ttlRunnable);
    }

    @Override
    public <T> ListenableFuture<T> submitListenable(Callable<T> task) {
        Callable ttlCallable = TtlCallable.get(task);
        return super.submitListenable(ttlCallable);
    }
}

2.这是我的TTL使用案例

@Service
public class Service{

    public Result useTtl(){
        try{
            // 1.主线程执行....


            // 2.使用 CompletableFuture
            CompletableFuture<Void> function_1 = CompletableFuture..runAsync(() -> todo, customThreadPoolTaskExecutor);
            CompletableFuture<Void> function_2 = CompletableFuture..runAsync(() -> todo, customThreadPoolTaskExecutor);
       
            // 3.等待 function_1 和 function_1 执行完成
            CompletableFuture.allOf(function_1,function_2).join();
        } finally{
            // remove ttl context
            TTL.remove();
        }
    }
}

以上代码，第3.等待 function_1 和 function_1 执行完成 的目的是为了让主线程等待，让子线程执行完成后再释放 TTL.remove();,但其实function_1和function_2的代码，是可以让后台线程执行，主线程无需等待得知结果。如果不加CompletableFuture.allOf(function_1,function_2).join();的代码，子线程未执行完成，但主线程已经执行了TTL.remove();，那么function_1和function_2还能拿到TTL的上下文吗？

[oldratlee]

1.这是我包装的Executor

你提到的ThreadPoolTaskExecutor是Spring的实现类吧？

可以考虑使用Spring的ThreadPoolTaskExecutor#setTaskDecorator()方法 完成统一修饰，避免繁琐易错地去override不同方法，也会更安全可靠： @kginglam

ThreadPoolTaskExecutor threadPoolTaskExecutor = ...
threadPoolTaskExecutor.setTaskDecorator(TtlRunnable::get);

---

如果不加CompletableFuture.allOf(function_1,function_2).join();的代码，子线程未执行完成，但主线程已经执行了TTL.remove();，那么function_1和function_2还能拿到TTL的上下文吗？

简单地说，可以的。 @kginglam

注意： ❗️
我这里「Remove之后可以」的前提是 异步执行。 @kginglam
同步执行在当前线程，Remove之后自然是没了。

CompletableFuture的任务执行不一定是异步的，可能/可以在当前线程中同步执行，可能需要了解影响，当然这些注意点与具体业务的使用逻辑是否正确相关。这些相关内容请具体请了解/调研 CompletableFuture。CompletableFuture以及并发 都是复杂主题，本身有挺多内容要了解、理解、注意。 💕

• 对于你自己的具体Case，你可以先直接测试运行一下，能实际确认到「是否可以」的结论
• 然后可以查看一下使用/运行到的TTL代码，进一步确认「可以」的原因
• 当然也可以去了解一下TTL的实现/设计/原理，这方面有较多内容介绍，比如看看 小伙伴同学们写的 TTL实际业务使用场景 与 设计实现解析的文章（写得都很好！ ）❤️ #123

PS：CompletableFuture的使用与理解好挺复杂的，会有要注意的地方；自己最近也在学习CompletableFuture 😄 整理实现的CompletableFuture辅助库 🦝 cffu。
PPS： 对于功能问题或Bug的反馈，推荐给一个 极简 可运行 复现问题 的Demo代码工程（比如一个GitHub repo工程）。 @kginglam