diff --git a/xiaoya_proxy/src/main/java/com/ddsrem/xiaoya_proxy/XiaoyaProxyHandler.java b/xiaoya_proxy/src/main/java/com/ddsrem/xiaoya_proxy/XiaoyaProxyHandler.java index db5f3c187..ca720c967 100644 --- a/xiaoya_proxy/src/main/java/com/ddsrem/xiaoya_proxy/XiaoyaProxyHandler.java +++ b/xiaoya_proxy/src/main/java/com/ddsrem/xiaoya_proxy/XiaoyaProxyHandler.java @@ -441,7 +441,7 @@ public synchronized int read(byte[] buffer, int off, int len) throws IOException } if (this.is == null ) { - runTask(threadNum); + runTask(threadNum < 1 ? 1 : threadNum); this.is = this.futureQueue.remove().get(); runTask(1); Logger.log(connId + "[read]:读取数据块:" + blockCounter);