method does not override or implement a method from a supertype

hippo4j-common/src/main/java/cn/hippo4j/common/executor/support/BlockingQueueTypeEnum.java

@@ -43,6 +43,7 @@ public enum BlockingQueueTypeEnum {
      * {@link java.util.concurrent.ArrayBlockingQueue}
      */
     ARRAY_BLOCKING_QUEUE(1, "ArrayBlockingQueue") {
+
         @Override
         <T> BlockingQueue<T> of(Integer capacity) {
             return new ArrayBlockingQueue<>(capacity);
@@ -53,6 +54,7 @@ public enum BlockingQueueTypeEnum {
      * {@link java.util.concurrent.LinkedBlockingQueue}
      */
     LINKED_BLOCKING_QUEUE(2, "LinkedBlockingQueue") {
+
         @Override
         <T> BlockingQueue<T> of(Integer capacity) {
             return new LinkedBlockingQueue<>(capacity);
@@ -63,6 +65,7 @@ public enum BlockingQueueTypeEnum {
      * {@link java.util.concurrent.LinkedBlockingDeque}
      */
     LINKED_BLOCKING_DEQUE(3, "LinkedBlockingDeque") {
+
         @Override
         <T> BlockingQueue<T> of() {
             return new LinkedBlockingDeque<>();
@@ -73,6 +76,7 @@ public enum BlockingQueueTypeEnum {
      * {@link java.util.concurrent.SynchronousQueue}
      */
     SYNCHRONOUS_QUEUE(4, "SynchronousQueue") {
+
         @Override
         <T> BlockingQueue<T> of() {
             return new SynchronousQueue<>();
@@ -83,6 +87,7 @@ public enum BlockingQueueTypeEnum {
      * {@link java.util.concurrent.LinkedTransferQueue}
      */
     LINKED_TRANSFER_QUEUE(5, "LinkedTransferQueue") {
+
         @Override
         <T> BlockingQueue<T> of() {
             return new LinkedTransferQueue<>();
@@ -93,6 +98,7 @@ public enum BlockingQueueTypeEnum {
      * {@link java.util.concurrent.PriorityBlockingQueue}
      */
     PRIORITY_BLOCKING_QUEUE(6, "PriorityBlockingQueue") {
+
         @Override
         <T> BlockingQueue<T> of(Integer capacity) {
             return new PriorityBlockingQueue<>(capacity);
@@ -103,6 +109,7 @@ public enum BlockingQueueTypeEnum {
      * {@link ResizableCapacityLinkedBlockingQueue}
      */
     RESIZABLE_LINKED_BLOCKING_QUEUE(9, "ResizableCapacityLinkedBlockingQueue") {
+
         @Override
         <T> BlockingQueue<T> of(Integer capacity) {
             return new ResizableCapacityLinkedBlockingQueue<>(capacity);
@@ -197,7 +204,6 @@ public enum BlockingQueueTypeEnum {
         ServiceLoaderRegistry.register(CustomBlockingQueue.class);
     }
 
-
     private static <T> BlockingQueue<T> customOrDefaultQueue(Integer capacity, Predicate<CustomBlockingQueue> predicate) {
         Collection<CustomBlockingQueue> customBlockingQueues = ServiceLoaderRegistry
                 .getSingletonServiceInstances(CustomBlockingQueue.class);

hippo4j-common/src/main/java/cn/hippo4j/common/executor/support/NotSupportedException.java

@@ -1,3 +1,20 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements.  See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License.  You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
 package cn.hippo4j.common.executor.support;
 
 import cn.hippo4j.common.web.exception.AbstractException;

hippo4j-common/src/main/java/cn/hippo4j/common/extension/reducer/AllMatch.java

@@ -37,7 +37,6 @@ public class AllMatch<Element> extends Reducer<Element, Boolean> {
     public AllMatch(@NonNull Predicate<Element> predicate) {
         Objects.requireNonNull(predicate);
         this.predicate = predicate;
-        setResult(true);
     }
 
     @Override

hippo4j-common/src/main/java/cn/hippo4j/common/extension/reducer/AnyMatch.java

@@ -37,7 +37,6 @@ public class AnyMatch<Element> extends Reducer<Element, Boolean> {
     public AnyMatch(@NonNull Predicate<Element> predicate) {
         Objects.requireNonNull(predicate);
         this.predicate = predicate;
-        this.setResult(false);
     }
 
     @Override

hippo4j-common/src/main/java/cn/hippo4j/common/extension/reducer/Reducer.java

@@ -44,4 +44,10 @@ public abstract class Reducer<Element, Result> {
 
     public abstract Result reduce();
 
+    public abstract ReduceType reducerType();
+
+    public String reduceName() {
+        return this.getClass().getSimpleName();
+    }
+
 }