feat(infra): add SyncPutQueuePolicyTest test class #1336

1. add SyncPutQueuePolicyTest test class

Co-authored-by: rnmb<19276209+rnmb@users.noreply.github.com>

infra/common/src/test/java/cn/hippo4j/common/executor/support/SyncPutQueuePolicyTest.java

@@ -0,0 +1,34 @@
+package cn.hippo4j.common.executor.support;
+
+import cn.hippo4j.common.toolkit.ThreadUtil;
+import org.junit.Assert;
+import org.junit.Test;
+
+import java.util.concurrent.*;
+import java.util.stream.IntStream;
+
+/**
+ * Synchronous placement queue policy implementation test
+ */
+public class SyncPutQueuePolicyTest {
+
+    /**
+     * test thread pool rejected execution
+     */
+    @Test
+    public void testRejectedExecution() throws InterruptedException {
+        SyncPutQueuePolicy syncPutQueuePolicy = new SyncPutQueuePolicy();
+        ThreadPoolExecutor threadPoolExecutor = new ThreadPoolExecutor(1, 2,
+                60, TimeUnit.SECONDS, new ArrayBlockingQueue<>(1), syncPutQueuePolicy);
+        threadPoolExecutor.prestartAllCoreThreads();
+
+        Assert.assertSame(syncPutQueuePolicy, threadPoolExecutor.getRejectedExecutionHandler());
+        IntStream.range(0, 4).forEach(s -> {
+            threadPoolExecutor.execute(() -> ThreadUtil.sleep(500L));
+        });
+        threadPoolExecutor.shutdown();
+        while (!threadPoolExecutor.isTerminated()) {
+        }
+        Assert.assertEquals(4, threadPoolExecutor.getCompletedTaskCount());
+    }
+}