TransmittableThreadLocal坑

2022-08-17 21:52:14 浏览数 (1)

巨大建筑,总是由一木一石叠起来,我们何妨做做这一木一石呢?我时常做些零碎事,就是为此。——鲁迅

今天遇到一个坑,在使用TransimittableThreadLocal(以下简称TTL)时,用了一会儿,在子线程中突然获取不到TTL在主线程中存储的变量了

翻了翻官方项目地址,发现我这里使用的CompletableFuture没有指定线程池,后来指定使用TtlExecutors包装的线程池就可以了

具体实现如下:

修改前:

代码语言:javascript复制
@SafeVarargs
   public static <T extends Model<T>, I> CompletableFuture<Map<I, List<T>>> asyncGroupBy(T entity, Collection<I> paramList, SFunction<T, I> sFunction, Consumer<T>... peeks) {
       return CompletableFuture.supplyAsync(() -> groupBy(entity, paramList, sFunction, peeks));
   }

修改后:

代码语言:javascript复制
   private static final Executor THREAD_POOL = TtlExecutors.getTtlExecutorService(ThreadUtil.newExecutor());

@SafeVarargs
   public static <T extends Model<T>, I> CompletableFuture<Map<I, List<T>>> asyncGroupBy(T entity, Collection<I> paramList, SFunction<T, I> sFunction, Consumer<T>... peeks) {
       return CompletableFuture.supplyAsync(() -> groupBy(entity, paramList, sFunction, peeks), THREAD_POOL);
   }

关于我写的这个groupBy函数我之前博客也发过了,这里就不赘述了,这里是用hutoolThreadUtil.newExecutor()创建的线程池

0 人点赞