From bef5f0a247d413f4046567dfff8abc251778decc Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E9=A1=BE=E9=B9=8F?= <gupeng@gupengdeMacBook-Pro.local>
Date: Fri, 2 Aug 2024 15:17:49 +0800
Subject: [PATCH] Fix
 alluxio.util.executor.UniqueBlockingQueueTest.concurrentTest fail

---
 .../alluxio/util/executor/UniqueBlockingQueueTest.java   | 9 +++++++++
 1 file changed, 9 insertions(+)

diff --git a/core/common/src/test/java/alluxio/util/executor/UniqueBlockingQueueTest.java b/core/common/src/test/java/alluxio/util/executor/UniqueBlockingQueueTest.java
index d7b91b7c88ce..ce5318ce0193 100644
--- a/core/common/src/test/java/alluxio/util/executor/UniqueBlockingQueueTest.java
+++ b/core/common/src/test/java/alluxio/util/executor/UniqueBlockingQueueTest.java
@@ -17,6 +17,7 @@
 
 import java.util.concurrent.ExecutorService;
 import java.util.concurrent.Executors;
+import java.util.concurrent.TimeUnit;
 
 /**
  * Tests the {@link UniqueBlockingQueue}.
@@ -51,6 +52,14 @@ public void concurrentTest() throws Exception {
       });
     }
     executor.shutdown();
+    try {
+      if (!executor.awaitTermination(60, TimeUnit.SECONDS)) {
+        executor.shutdownNow();
+      }
+    } catch (InterruptedException e) {
+      executor.shutdownNow();
+      Thread.currentThread().interrupt();
+    }
     assertEquals(20, test.size());
   }
 }