diff --git a/hutool-core/src/main/java/cn/hutool/core/thread/ExecutorBuilder.java b/hutool-core/src/main/java/cn/hutool/core/thread/ExecutorBuilder.java index 054002458..0d944303c 100644 --- a/hutool-core/src/main/java/cn/hutool/core/thread/ExecutorBuilder.java +++ b/hutool-core/src/main/java/cn/hutool/core/thread/ExecutorBuilder.java @@ -118,7 +118,7 @@ public class ExecutorBuilder implements Builder { * @since 4.5.0 */ public ExecutorBuilder useSynchronousQueue(boolean fair) { - return setWorkQueue(new SynchronousQueue(fair)); + return setWorkQueue(new SynchronousQueue<>(fair)); } /** @@ -190,7 +190,7 @@ public class ExecutorBuilder implements Builder { workQueue = builder.workQueue; } else { // corePoolSize为0则要使用SynchronousQueue避免无限阻塞 - workQueue = (corePoolSize <= 0) ? new SynchronousQueue() : new LinkedBlockingQueue(); + workQueue = (corePoolSize <= 0) ? new SynchronousQueue<>() : new LinkedBlockingQueue<>(); } final ThreadFactory threadFactory = (null != builder.threadFactory) ? builder.threadFactory : Executors.defaultThreadFactory(); RejectedExecutionHandler handler = ObjectUtil.defaultIfNull(builder.handler, new ThreadPoolExecutor.AbortPolicy());