You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by ro...@apache.org on 2023/05/31 08:05:29 UTC
[iotdb] 03/03: ArrayBlockingQueue
This is an automated email from the ASF dual-hosted git repository.
rong pushed a commit to branch reduce-submit-self
in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 5813c76c3d0c905f188c2c7a77aebd6e4d7e2ba6
Author: Steve Yurong Su <ro...@apache.org>
AuthorDate: Wed May 31 16:05:00 2023 +0800
ArrayBlockingQueue
---
.../db/pipe/task/queue/ListenableBoundedBlockingPendingQueue.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git a/server/src/main/java/org/apache/iotdb/db/pipe/task/queue/ListenableBoundedBlockingPendingQueue.java b/server/src/main/java/org/apache/iotdb/db/pipe/task/queue/ListenableBoundedBlockingPendingQueue.java
index da91cc4187b..1614f738254 100644
--- a/server/src/main/java/org/apache/iotdb/db/pipe/task/queue/ListenableBoundedBlockingPendingQueue.java
+++ b/server/src/main/java/org/apache/iotdb/db/pipe/task/queue/ListenableBoundedBlockingPendingQueue.java
@@ -21,12 +21,12 @@ package org.apache.iotdb.db.pipe.task.queue;
import org.apache.iotdb.pipe.api.event.Event;
-import org.eclipse.jetty.util.BlockingArrayQueue;
+import java.util.concurrent.ArrayBlockingQueue;
public class ListenableBoundedBlockingPendingQueue<E extends Event>
extends ListenableBlockingPendingQueue<E> {
public ListenableBoundedBlockingPendingQueue(int pendingQueueSize) {
- super(new BlockingArrayQueue<>(pendingQueueSize));
+ super(new ArrayBlockingQueue<>(pendingQueueSize));
}
}