diff --git a/core/api/src/test/java/com/alipay/sofa/rpc/config/UserThreadPoolManagerTest.java b/core/api/src/test/java/com/alipay/sofa/rpc/config/UserThreadPoolManagerTest.java index 810a61f2f..cd9e6dfed 100644 --- a/core/api/src/test/java/com/alipay/sofa/rpc/config/UserThreadPoolManagerTest.java +++ b/core/api/src/test/java/com/alipay/sofa/rpc/config/UserThreadPoolManagerTest.java @@ -18,6 +18,7 @@ import com.alipay.sofa.rpc.server.UserThreadPool; import com.alipay.sofa.rpc.server.UserVirtualThreadPool; +import com.alipay.sofa.rpc.server.SofaRejectedExecutionHandler; import org.junit.Assert; import org.junit.Test; import java.util.Set; @@ -67,6 +68,14 @@ public void userThreadPoolBuildTest() { Assert.assertNull(result); } + @Test + public void testRejectedExecutionHandler(){ + UserThreadPool userThreadPool = new UserThreadPool(); + Executor executorService = userThreadPool.getUserExecutor(); + Assert.assertTrue(executorService instanceof ThreadPoolExecutor); + Assert.assertTrue(((ThreadPoolExecutor) executorService).getRejectedExecutionHandler() instanceof SofaRejectedExecutionHandler); + } + @Test public void userThreadPoolCompatibleTest() { UserThreadPool userThreadPool = new UserThreadPool();