diff --git a/src/main/java/com/ctrip/zeus/service/nginx/impl/NginxServiceImpl.java b/src/main/java/com/ctrip/zeus/service/nginx/impl/NginxServiceImpl.java index a52d40d4..f6088bc8 100644 --- a/src/main/java/com/ctrip/zeus/service/nginx/impl/NginxServiceImpl.java +++ b/src/main/java/com/ctrip/zeus/service/nginx/impl/NginxServiceImpl.java @@ -100,6 +100,7 @@ public class NginxServiceImpl implements NginxService { return response; } }); + threadPoolExecutor.execute(futureTask); futureTasks.add(futureTask); } @@ -225,12 +226,6 @@ public class NginxServiceImpl implements NginxService { } } - @Override - public List writeALLToDiskListResult(Long slbId,Integer slbVersion ,List vsIds ) throws Exception { - List result = new ArrayList<>(); - writeALLToDisk(slbId, slbVersion ,vsIds, result); - return result; - } public boolean writeALLToDisk(Long slbId,Integer slbVersion , List vsIds , List responses) throws Exception { List result = null; @@ -344,22 +339,6 @@ public class NginxServiceImpl implements NginxService { } - @Override - public List writeAllAndLoadAll(Long slbId,Integer slbVersion,List vsIds) throws Exception { - List result = new ArrayList<>(); - if (!writeALLToDisk(slbId,slbVersion,vsIds, result)) { - LOGGER.error("Write All To Disk Failed!"); - StringBuilder sb = new StringBuilder(128); - sb.append("["); - for (NginxResponse res : result) { - sb.append(String.format(NginxResponse.JSON, res)).append(",\n"); - } - sb.append("]"); - throw new Exception("Write All To Disk Failed!\nDetail:\n" + sb.toString()); - } - result = loadAll(slbId , slbVersion); - return result; - } @Override public NginxResponse dyopsLocal(String upsName, String upsCommands) throws Exception {