fix test case

Author: yanhom1314

test/test-core/src/test/java/org/dromara/dynamictp/test/core/notify/capture/CapturedBlockingQueueTest.java

@@ -17,16 +17,13 @@
 
 package org.dromara.dynamictp.test.core.notify.capture;
 
-import org.dromara.dynamictp.common.queue.VariableLinkedBlockingQueue;
+import org.dromara.dynamictp.core.executor.DtpExecutor;
 import org.dromara.dynamictp.core.notifier.capture.CapturedBlockingQueue;
 import org.dromara.dynamictp.core.support.ThreadPoolBuilder;
-import org.dromara.dynamictp.core.executor.DtpExecutor;
 import org.junit.jupiter.api.Assertions;
 import org.junit.jupiter.api.BeforeAll;
-import org.junit.jupiter.api.RepeatedTest;
 import org.junit.jupiter.api.Test;
 
-import java.util.concurrent.BlockingQueue;
 import java.util.concurrent.TimeUnit;
 
 import static org.dromara.dynamictp.common.em.QueueTypeEnum.VARIABLE_LINKED_BLOCKING_QUEUE;
@@ -61,59 +58,19 @@ public static void setUp() {
     public void testBlockingQueueDefaultCapacity() {
         CapturedBlockingQueue capturedBlockingQueue = new CapturedBlockingQueue(dtpExecutor);
         Assertions.assertEquals(0, capturedBlockingQueue.size());
-        Assertions.assertEquals(Integer.MAX_VALUE, capturedBlockingQueue.remainingCapacity());
-    }
-
-    @Test
-    public void testBlockingQueueCapacitySet() {
-        final int capacity = 100;
-        BlockingQueue<Runnable> queue = new VariableLinkedBlockingQueue<>(capacity);
-        CapturedBlockingQueue capturedBlockingQueue = new CapturedBlockingQueue(dtpExecutor);
-        Assertions.assertEquals(capacity, capturedBlockingQueue.remainingCapacity());
+        Assertions.assertEquals(100, capturedBlockingQueue.remainingCapacity());
     }
 
     @Test
     public void testPut() {
-        BlockingQueue<Runnable> queue = new VariableLinkedBlockingQueue<>();
         CapturedBlockingQueue capturedBlockingQueue = new CapturedBlockingQueue(dtpExecutor);
         Assertions.assertThrows(UnsupportedOperationException.class, () ->
                 capturedBlockingQueue.put(() -> System.out.println("can't put Runnable to CapturedBlockingQueue")));
     }
 
     @Test
     public void testTake() {
-        BlockingQueue<Runnable> queue = new VariableLinkedBlockingQueue<>();
         CapturedBlockingQueue capturedBlockingQueue = new CapturedBlockingQueue(dtpExecutor);
         Assertions.assertThrows(UnsupportedOperationException.class, capturedBlockingQueue::take);
     }
-
-    @RepeatedTest(100)
-    public void testBlockingQueuePut() throws InterruptedException {
-        final int capacity = 100;
-        final int firstPutSize = 30;
-        final int secondPutSize = 40;
-
-        BlockingQueue<Runnable> queue = new VariableLinkedBlockingQueue<>(capacity);
-        putTaskToQueue(firstPutSize, queue);
-        CapturedBlockingQueue capturedBlockingQueue = new CapturedBlockingQueue(dtpExecutor);
-
-        Assertions.assertEquals(capacity - firstPutSize, capturedBlockingQueue.remainingCapacity());
-        Assertions.assertEquals(firstPutSize, capturedBlockingQueue.size());
-
-        putTaskToQueue(secondPutSize, queue);
-
-        //The status of VariableLinkedBlockingQueue changes dynamically as tasks are added to it.
-        Assertions.assertEquals(capacity - firstPutSize - secondPutSize, queue.remainingCapacity());
-        Assertions.assertEquals(firstPutSize + secondPutSize, queue.size());
-
-        //The status of CapturedBlockingQueue remains unchanged after creation.
-        Assertions.assertEquals(capacity - firstPutSize, capturedBlockingQueue.remainingCapacity());
-        Assertions.assertEquals(firstPutSize, capturedBlockingQueue.size());
-    }
-
-    private void putTaskToQueue(int size, BlockingQueue<Runnable> queue) throws InterruptedException {
-        for (int i = 0; i < size; i++) {
-            queue.put(() -> System.out.println("i am mock task"));
-        }
-    }
 }