Dev

src/main/java/com/igeeksky/xtool/core/AsyncCloseable.java

@@ -0,0 +1,22 @@
+package com.igeeksky.xtool.core;
+
+import java.util.concurrent.CompletableFuture;
+
+/**
+ * 异步关闭接口
+ * <p>
+ * IO 操作类对象建议实现此接口。
+ *
+ * @author Patrick.Lau
+ * @since 1.1.3
+ */
+public interface AsyncCloseable {
+
+    /**
+     * 异步关闭
+     *
+     * @return 异步关闭
+     */
+    CompletableFuture<Void> closeAsync();
+
+}

src/test/java/com/igeeksky/xtool/core/collection/RingBufferTest.java

@@ -8,6 +8,7 @@
 import java.util.Set;
 import java.util.concurrent.ArrayBlockingQueue;
 import java.util.concurrent.CountDownLatch;
+import java.util.concurrent.TimeUnit;
 import java.util.concurrent.atomic.AtomicInteger;
 import java.util.concurrent.locks.LockSupport;
 import java.util.function.Consumer;
@@ -375,7 +376,7 @@ void test_TwoOffer_TwoConsumer_Concurrently() throws InterruptedException {
     }
 
     @Test
-    void test_TwoOffer_OnePoll_Concurrently() {
+    void test_TwoOffer_OnePoll_Concurrently() throws InterruptedException {
         RingBuffer<String> buffer = new RingBuffer<>(2048);
         StringConsumer consumer = new StringConsumer();
         CountDownLatch latch = new CountDownLatch(2);
@@ -401,14 +402,15 @@ void test_TwoOffer_OnePoll_Concurrently() {
         thread1.start();
         thread2.start();
 
+        latch.await(2000, TimeUnit.MILLISECONDS);
+
         for (int i = 0; i < 2001; i++) {
             String polled = buffer.poll();
             if (polled != null) {
                 consumer.accept(polled);
                 continue;
             }
             assertEquals(consumer.getCount(), buffer.reads());
-            LockSupport.parkNanos(100);
         }
 
         Set<String> values = consumer.getValues();