Update XiaoyaProxyHandler.java

DDS-Derek · Jul 23, 2024 · d61be33 · d61be33
1 parent 17a8c12
commit d61be33
Showing 1 changed file with 1 addition and 1 deletion.
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
@@ -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);