From e2a356066102965cd9df0bef48d45055640905c5 Mon Sep 17 00:00:00 2001 From: redkale Date: Mon, 21 Oct 2024 14:29:27 +0800 Subject: [PATCH] pipelineWrite --- src/main/java/org/redkale/net/AsyncConnection.java | 6 +++--- src/main/java/org/redkale/net/AsyncNioConnection.java | 6 ++++-- 2 files changed, 7 insertions(+), 5 deletions(-) diff --git a/src/main/java/org/redkale/net/AsyncConnection.java b/src/main/java/org/redkale/net/AsyncConnection.java index f642f95a4..e60af3094 100644 --- a/src/main/java/org/redkale/net/AsyncConnection.java +++ b/src/main/java/org/redkale/net/AsyncConnection.java @@ -208,10 +208,10 @@ public abstract class AsyncConnection implements Channel, AutoCloseable { /** * 快速发送 * - * @see org.redkale.net.AsyncNioConnection#pipelineWrite(org.redkale.net.PipelinePacket) - * @param packet PipelinePacket + * @see org.redkale.net.AsyncNioConnection#pipelineWrite(org.redkale.net.PipelinePacket...) + * @param packets PipelinePacket[] */ - public abstract void pipelineWrite(PipelinePacket packet); + public abstract void pipelineWrite(PipelinePacket... packets); public abstract boolean isTCP(); diff --git a/src/main/java/org/redkale/net/AsyncNioConnection.java b/src/main/java/org/redkale/net/AsyncNioConnection.java index 33d0255b5..4536d065b 100644 --- a/src/main/java/org/redkale/net/AsyncNioConnection.java +++ b/src/main/java/org/redkale/net/AsyncNioConnection.java @@ -158,7 +158,7 @@ abstract class AsyncNioConnection extends AsyncConnection { } @Override - public final void pipelineWrite(PipelinePacket packet) { + public final void pipelineWrite(PipelinePacket... packets) { if (pipelineWriteQueue == null) { pipelineLock.lock(); try { @@ -169,7 +169,9 @@ abstract class AsyncNioConnection extends AsyncConnection { pipelineLock.unlock(); } } - this.pipelineWriteQueue.offer(packet); + for (PipelinePacket packet : packets) { + this.pipelineWriteQueue.offer(packet); + } this.ioWriteThread.execute(this::pipelineDoWrite); }