[fix][test] fix flaky GrowableArrayBlockingQueueTest.testPollBlockingThreadsTermination (#24576)

Co-authored-by: Lari Hotari <[email protected]>
(cherry picked from commit e5cd79a)

Author: 3pacccccc

pulsar-broker/src/test/java/org/apache/pulsar/client/api/SimpleProducerConsumerTest.java

@@ -4091,8 +4091,8 @@ public void multiThreadConsumerReceiveThrowExceptionWhenConsumerClose() throws E
                     consumer.receive();
                     fail("thread should have been interrupted");
                 } catch (PulsarClientException e) {
-                    terminateCompletedLatch.countDown();
                     interruptedThreadCount.incrementAndGet();
+                    terminateCompletedLatch.countDown();
                 }
             }).start();
         }

pulsar-common/src/test/java/org/apache/pulsar/common/util/collections/GrowableArrayBlockingQueueTest.java

@@ -229,8 +229,8 @@ public void testTakeBlockingThreadsTermination() throws InterruptedException {
                     fail("thread should have been interrupted");
                 } catch (InterruptedException e) {
                     // Expected interruption, record and notify
-                    terminateCompletedLatch.countDown();
                     interruptedThreadCount.incrementAndGet();
+                    terminateCompletedLatch.countDown();
                 }
             }).start();
         }
@@ -263,8 +263,8 @@ public void testPollBlockingThreadsTermination() throws InterruptedException {
                     Integer poll = queue.poll(1, TimeUnit.HOURS);
                     // should return a null value if queue is terminated
                     assertNull(poll);
-                    terminateCompletedLatch.countDown();
                     terminateThreadCount.incrementAndGet();
+                    terminateCompletedLatch.countDown();
                 } catch (InterruptedException e) {
                     throw new RuntimeException(e);
                 }
@@ -298,15 +298,15 @@ public void testPollTakeMixBlockingThreadsTermination() throws InterruptedExcept
                     try {
                         queue.take();
                     } catch (InterruptedException e) {
-                        terminateCompletedLatch.countDown();
                         terminateThreadCount.incrementAndGet();
+                        terminateCompletedLatch.countDown();
                     }
                 } else {
                     try {
                         Integer poll = queue.poll(1, TimeUnit.HOURS);
                         assertNull(poll);
-                        terminateCompletedLatch.countDown();
                         terminateThreadCount.incrementAndGet();
+                        terminateCompletedLatch.countDown();
                     } catch (InterruptedException e) {
                         throw new RuntimeException(e);
                     }