FutureTask/CompletableFuture的异步任务场景下，TTL的使用

[liaofanxin]

请问在JDK1.8，CompletableFuture的异步任务的时候，如果做兼容？有demo可以参考一下吗

[oldratlee]

1. FutureTask

你说到的FutureTask是指java.util.concurrent.FutureTask，是吧。 @liaofanxin

java.util.concurrent.FutureTask是Runnable，一般是在ThreadPoolExecutor中执行，可以通过TTL文档的说明的方法来使用：

• 2.1 修饰Runnable和Callable
• 2.2 修饰线程池
• 2.3 使用Java Agent来修饰JDK线程池实现类

这3个背后都是修饰Runnable，只是使用方式不同。

2. CompletableFuture

CompletableFuture的执行，缺省使用ForkJoinPool作为执行器，底下转成ForkJoinPool的ForkJoinTask来执行，使用文档中2.3 使用Java Agent来修饰JDK线程池实现类的方式，透明支持CompletableFuture的TTL：

参见Issue

• support ForkJoinPool of jdk 7 #76 support ForkJoinPool of jdk 7
• 如何在CompletableFuture中开启TTL支持？ #151 如何在CompletableFuture中开启TTL支持？

3. Stream

与上面的CompletableFuture一样，（并行执行的）Stream底层通过ForkJoinPool执行。

所以也是使用 文档中2.3 使用Java Agent来修饰JDK线程池实现类的方式，透明支持Stream的TTL。

参见Issue

• TTL agent support parallel stream of jdk 8 #77 TTL agent support parallel stream of jdk 8
• 线程内部使用了parallel stream 的场景下TTL的使用 #108 线程内部使用了parallel stream 的场景下TTL的使用

[liaofanxin]

多谢回复，已经找到解决办法，项目中已经引入，测试没问题，已发布上线 发自我的iPhone

…

------------------ 原始邮件 ------------------ 发件人: 李鼎(哲良) <[email protected]&gt; 发送时间: 2019年11月29日 21:32 收件人: alibaba/transmittable-thread-local <[email protected]&gt; 抄送: 辛令剑 <[email protected]&gt;, Mention <[email protected]&gt; 主题: 回复：[alibaba/transmittable-thread-local] FutureTask/CompletableFuture的异步任务场景下，TTL的使用 (#154) Closed #154. — You are receiving this because you were mentioned. Reply to this email directly, view it on GitHub, or unsubscribe.

[oldratlee]

已经找到解决办法，项目中已经引入，测试没问题，已发布上线

👏👍

能说一下你的场景和解决方法吗？😀 ❤️@liaofanxin

[liaofanxin]

# 使用场景 项目的日志tag（例如用户uid，订单id等），采用threadlocal来进行透传，但是在启用future或者threadpool来执行异步任务的时候，threadlocal中的日志tag是不能正常传递的。 # 原因 1. threadlocal线程隔离 2. InherbritableThreadLocal虽然可以解决线程隔离问题，但是无法解决线程池线程复用导致的日志tag混乱问题 # 原先解决方案： 1. 执行异步任务前重新获取threadlocal中的tag，然后在开启新任务的地方重新setThreadlocal 2. tag作为参数进行传递 # 引入TTL后的方案 1. 采用ttl的TransmittableThreadLocal存储日志tag 2. 用TtlExecutors封装ThreadPool帮助类 3. 使用CompletableFuture并制定Executor 发自我的iPhone

…

------------------ 原始邮件 ------------------ 发件人: 李鼎(哲良) <[email protected]&gt; 发送时间: 2019年11月29日 21:45 收件人: alibaba/transmittable-thread-local <[email protected]&gt; 抄送: 辛令剑 <[email protected]&gt;, Mention <[email protected]&gt; 主题: 回复：[alibaba/transmittable-thread-local] FutureTask/CompletableFuture的异步任务场景下，TTL的使用 (#154) 能说一下你的场景和解决方法吗？😀 @liaofanxin — You are receiving this because you were mentioned. Reply to this email directly, view it on GitHub, or unsubscribe.

[oldratlee]

引入TTL后的方案

……
3. 使用CompletableFuture并制定Executor

关于『使用CompletableFuture并制定Executor』这点，对CompletableFuture及其使用ForkJoinPool Executor你是如何定制的？ @liaofanxin 😁

• 使用了『2.3 使用Java Agent来修饰JDK线程池实现类』的Java Agent方式吗？
• 如果没有使用Java Agent，你是如何做的？

[liaofanxin]

使用了2.3对用ForkJoinPool Executor进行修饰 发自我的iPhone

…

------------------ 原始邮件 ------------------ 发件人: 李鼎(哲良) <[email protected]&gt; 发送时间: 2019年11月30日 14:13 收件人: alibaba/transmittable-thread-local <[email protected]&gt; 抄送: 辛令剑 <[email protected]&gt;, Mention <[email protected]&gt; 主题: 回复：[alibaba/transmittable-thread-local] FutureTask/CompletableFuture的异步任务场景下，TTL的使用 (#154) 引入TTL后的方案 …… 3. 使用CompletableFuture并制定Executor 关于『使用CompletableFuture并制定Executor』这点，对CompletableFuture及其使用ForkJoinPool Executor你是如何定制的？ @liaofanxin 使用了『2.3 使用Java Agent来修饰JDK线程池实现类』的Java Agent方式吗？ 如果没有使用Java Agent，你是如何做的？ — You are receiving this because you were mentioned. Reply to this email directly, view it on GitHub, or unsubscribe.

[LouisProgress]

CompletableFuture

对的CompletableFuture的支持，能否分享一个demo，感谢！

[liaofanxin]

你好,您刚才发给我的邮件我已经收到! 祝工作顺利,事事顺心! 谢谢你的邮件!