Fix ElasticJobExecutorServiceTest Flakiness (#2242)

Co-authored-by: other <other@ECE-A55006.austin.utexas.edu>
apache · Sep 5, 2023 · 53cbc73 · 53cbc73
1 parent 2dc90ee
commit 53cbc73
Showing 1 changed file with 6 additions and 0 deletions.
diff --git a/.../org/apache/shardingsphere/elasticjob/infra/concurrent/ElasticJobExecutorServiceTest.java b/.../org/apache/shardingsphere/elasticjob/infra/concurrent/ElasticJobExecutorServiceTest.java
@@ -28,6 +28,8 @@
 
 public final class ElasticJobExecutorServiceTest {
 
+    private static boolean hasExecuted;
+
     @Test
     public void assertCreateExecutorService() {
         ElasticJobExecutorService executorServiceObject = new ElasticJobExecutorService("executor-service-test", 1);
@@ -48,13 +50,17 @@ public void assertCreateExecutorService() {
         executorService.shutdownNow();
         assertThat(executorServiceObject.getWorkQueueSize(), is(0));
         assertTrue(executorServiceObject.isShutdown());
+        hasExecuted = true;
     }
 
     static class FooTask implements Runnable {
 
         @Override
         public void run() {
             BlockUtils.sleep(1000L);
+            while (!hasExecuted) {
+                Thread.yield();
+            }
         }
     }
 }