Authored by qinchao

线程池数量调整

@@ -55,7 +55,7 @@ public class AppraiseService { @@ -55,7 +55,7 @@ public class AppraiseService {
55 55
56 private static final Logger LOGGER = LoggerFactory.getLogger(AppraiseService.class); 56 private static final Logger LOGGER = LoggerFactory.getLogger(AppraiseService.class);
57 57
58 - private ExecutorService executorService = new ThreadPoolExecutor(5, 10, 60, TimeUnit.SECONDS, new ArrayBlockingQueue<>(10), new PubThreadFactory("appraise-processor")); 58 + private ExecutorService executorService = new ThreadPoolExecutor(3, 5, 60, TimeUnit.SECONDS, new ArrayBlockingQueue<>(100), new PubThreadFactory("appraise-processor"));
59 59
60 @Autowired 60 @Autowired
61 private IExpressInfoService expressInfoService; 61 private IExpressInfoService expressInfoService;
@@ -22,7 +22,7 @@ public class InBoxFacade { @@ -22,7 +22,7 @@ public class InBoxFacade {
22 22
23 private final Logger logger = LoggerFactory.getLogger(getClass()); 23 private final Logger logger = LoggerFactory.getLogger(getClass());
24 24
25 - private ExecutorService executorService = new ThreadPoolExecutor(10, 60, 60, TimeUnit.SECONDS, new ArrayBlockingQueue<>(30), new InBoxThreadFactory()); 25 + private ExecutorService executorService = new ThreadPoolExecutor(5, 10, 60, TimeUnit.SECONDS, new ArrayBlockingQueue<>(1000), new InBoxThreadFactory());
26 26
27 @Autowired 27 @Autowired
28 private InBoxSDK inBoxSDK; 28 private InBoxSDK inBoxSDK;