src/main/java/com/zy/core/thread/impl/NyShuttleThread.java
@@ -89,7 +89,7 @@ while (true) { try { read(); Thread.sleep(50); Thread.sleep(200); } catch (Exception e) { log.error("ShuttleThread Fail", e); } @@ -194,7 +194,7 @@ } JSONObject result = JSON.parseObject(sb.toString());//得到响应结果集 if (!socketResults.isEmpty() && socketResults.size() >= 20) { if (!socketResults.isEmpty() && socketResults.size() >= 100) { socketResults.remove(0);//清理头节点 } socketResults.add(result);//添加数据