chore(stream): move asyncsemaphore to util (#2173)

Signed-off-by: Robin Han <[email protected]>
AutoMQ · Nov 22, 2024 · d7b73f0 · d7b73f0
1 parent e9bbf7a
commit d7b73f0
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 2 deletions.
diff --git a/s3stream/src/main/java/com/automq/stream/s3/cache/blockcache/DataBlockCache.java b/s3stream/src/main/java/com/automq/stream/s3/cache/blockcache/DataBlockCache.java
@@ -18,6 +18,7 @@
 import com.automq.stream.s3.metrics.S3StreamMetricsManager;
 import com.automq.stream.s3.metrics.stats.StorageOperationStats;
 import com.automq.stream.s3.network.ThrottleStrategy;
+import com.automq.stream.utils.AsyncSemaphore;
 import com.automq.stream.utils.FutureUtil;
 import com.automq.stream.utils.Time;
 import com.automq.stream.utils.threads.EventLoop;

diff --git a/...m/s3/cache/blockcache/AsyncSemaphore.java → ...m/automq/stream/utils/AsyncSemaphore.java b/...m/s3/cache/blockcache/AsyncSemaphore.java → ...m/automq/stream/utils/AsyncSemaphore.java
@@ -9,7 +9,7 @@
  * by the Apache License, Version 2.0
  */
 
-package com.automq.stream.s3.cache.blockcache;
+package com.automq.stream.utils;
 
 import com.automq.stream.utils.threads.EventLoop;
 
@@ -21,7 +21,7 @@
 import java.util.concurrent.CompletableFuture;
 import java.util.function.Supplier;
 
-class AsyncSemaphore {
+public class AsyncSemaphore {
     private static final Logger LOGGER = LoggerFactory.getLogger(AsyncSemaphore.class);
     private final Queue<AsyncSemaphoreTask> tasks = new LinkedList<>();
     private long permits;