[fix][test] Fix thread leak in concurrent collections tests (apache#2…

…1449)
streamnative · Oct 27, 2023 · b5ac129 · b5ac129
1 parent 2b5c199
commit b5ac129
Show file tree

Hide file tree

Showing 4 changed files with 4 additions and 4 deletions.
diff --git a/...est/java/org/apache/pulsar/common/util/collections/ConcurrentLongLongPairHashMapTest.java b/...est/java/org/apache/pulsar/common/util/collections/ConcurrentLongLongPairHashMapTest.java
@@ -203,7 +203,7 @@ public void testConcurrentExpandAndShrinkAndGet()  throws Throwable {
                 } catch (Exception e) {
                     throw new RuntimeException(e);
                 }
-                while (true) {
+                while (!Thread.currentThread().isInterrupted()) {
                     try {
                         map.get(1, 1);
                     } catch (Exception e) {

diff --git a/...on/src/test/java/org/apache/pulsar/common/util/collections/ConcurrentLongPairSetTest.java b/...on/src/test/java/org/apache/pulsar/common/util/collections/ConcurrentLongPairSetTest.java
@@ -239,7 +239,7 @@ public void testConcurrentExpandAndShrinkAndGet()  throws Throwable {
                 } catch (Exception e) {
                     throw new RuntimeException(e);
                 }
-                while (true) {
+                while (!Thread.currentThread().isInterrupted()) {
                     try {
                         set.contains(1, 1);
                     } catch (Exception e) {

diff --git a/...on/src/test/java/org/apache/pulsar/common/util/collections/ConcurrentOpenHashMapTest.java b/...on/src/test/java/org/apache/pulsar/common/util/collections/ConcurrentOpenHashMapTest.java
@@ -243,7 +243,7 @@ public void testConcurrentExpandAndShrinkAndGet()  throws Throwable {
                 } catch (Exception e) {
                     throw new RuntimeException(e);
                 }
-                while (true) {
+                while (!Thread.currentThread().isInterrupted()) {
                     try {
                         map.get("k2");
                     } catch (Exception e) {

diff --git a/...on/src/test/java/org/apache/pulsar/common/util/collections/ConcurrentOpenHashSetTest.java b/...on/src/test/java/org/apache/pulsar/common/util/collections/ConcurrentOpenHashSetTest.java
@@ -214,7 +214,7 @@ public void testConcurrentExpandAndShrinkAndGet()  throws Throwable {
                 } catch (Exception e) {
                     throw new RuntimeException(e);
                 }
-                while (true) {
+                while (!Thread.currentThread().isInterrupted()) {
                     try {
                         set.contains("k2");
                     } catch (Exception e) {