diff --git a/core/api/src/main/java/com/alipay/sofa/rpc/context/AsyncRuntime.java b/core/api/src/main/java/com/alipay/sofa/rpc/context/AsyncRuntime.java index a5970bf3c..0a6bb801e 100644 --- a/core/api/src/main/java/com/alipay/sofa/rpc/context/AsyncRuntime.java +++ b/core/api/src/main/java/com/alipay/sofa/rpc/context/AsyncRuntime.java @@ -100,4 +100,13 @@ public void rejectedExecution(Runnable r, ThreadPoolExecutor executor) { } return asyncThreadPool; } + + /** + * 设置callback用的线程池 + * + * @param threadPoolExecutor callback用的线程池 + */ + public static void setAsyncThreadPool(ThreadPoolExecutor threadPoolExecutor) { + AsyncRuntime.asyncThreadPool = threadPoolExecutor; + } }