Improve MemoryPipelineChannelTest for nightly CI (#29677)

kernel/data-pipeline/core/src/test/java/org/apache/shardingsphere/data/pipeline/core/channel/memory/MemoryPipelineChannelTest.java

@@ -26,10 +26,13 @@
 
 import java.util.Collections;
 import java.util.List;
+import java.util.concurrent.Semaphore;
+import java.util.concurrent.TimeUnit;
 import java.util.concurrent.atomic.AtomicReference;
 
 import static org.hamcrest.CoreMatchers.is;
 import static org.hamcrest.MatcherAssert.assertThat;
+import static org.junit.jupiter.api.Assertions.assertTrue;
 
 class MemoryPipelineChannelTest {
 
@@ -38,10 +41,14 @@ class MemoryPipelineChannelTest {
     void assertZeroQueueSizeWorks() {
         MemoryPipelineChannel channel = new MemoryPipelineChannel(0, new InventoryTaskAckCallback(new AtomicReference<>()));
         List<Record> records = Collections.singletonList(new PlaceholderRecord(new IngestFinishedPosition()));
-        Thread thread = new Thread(() -> channel.push(records));
+        Semaphore semaphore = new Semaphore(1);
+        Thread thread = new Thread(() -> {
+            semaphore.release();
+            channel.push(records);
+        });
         thread.start();
-        assertThat(channel.fetch(1, 5L), is(records));
-        thread.join();
+        assertTrue(semaphore.tryAcquire(1L, TimeUnit.SECONDS));
+        assertThat(channel.fetch(1, 50L), is(records));
     }
 
     @Test