【fix】 线程使用完后使用主线程执行 ThreadPoolExecutor.AbortPolicy()

This commit is contained in:
wujiawei 2024-09-03 16:46:20 +08:00
parent b9d75715de
commit 9bf26e99d0

View File

@ -19,7 +19,8 @@ public class ChannelFlowAdapter {
ThreadPoolExecutor CHANNEL_FLOW_ADAPTER_EXECUTOR =
new ThreadPoolExecutor(20, 200, 3L, TimeUnit.MINUTES,
new LinkedBlockingDeque<>(500));
new LinkedBlockingDeque<>(500),new ThreadPoolExecutor.AbortPolicy());
// 线程使用完后使用主线程执行