2023年11月27日18:54:20 任务被拒绝, 抛异常

王明元
1 parent 2e5038e7
Showing 1 changed file with 5 additions and 2 deletions
src/main/java/cn/fw/freya/utils/ThreadPoolUtil.java
@@ -33,7 +33,7 @@ public class ThreadPoolUtil {
                             TimeUnit.SECONDS,
                             new LinkedBlockingQueue<>(128),
                             new ThreadFactoryBuilder().setNamePrefix("capture-pool-").build(),
-                            new ThreadPoolExecutor.DiscardPolicy()
+                            new ThreadPoolUtil.UserDiscardPolicy()
                     );// 自行创建线程池, 并将创建好的线程池对象赋值给类的静态成员变量threadPool
                 }
                 return threadPool;// 将创建好的线程池对象返回
@@ -67,10 +67,13 @@ public class ThreadPoolUtil {
         getThreadPool().shutdown();
     }
  
+    /**
+     * 自定义线程池拒绝策略
+     */
     public static class UserDiscardPolicy implements RejectedExecutionHandler {
         @Override
         public void rejectedExecution(Runnable r, ThreadPoolExecutor executor) {
-
+            throw new RejectedExecutionException("任务被拒绝");
         }
     }