|
@@ -315,12 +315,12 @@ public class CoreServiceImpl implements CoreService {
|
|
|
|
|
|
|
|
|
// 定义一个阻塞队列
|
|
|
- private static final ArrayBlockingQueue<MatchContent> matchQueue = new ArrayBlockingQueue<>(100000);
|
|
|
+ private static final ArrayBlockingQueue<MatchContent> matchQueue = new ArrayBlockingQueue<>(1000000);
|
|
|
|
|
|
- private static final ArrayBlockingQueue<PlanAccount> coreQueue = new ArrayBlockingQueue<>(100000);
|
|
|
+ private static final ArrayBlockingQueue<PlanAccount> coreQueue = new ArrayBlockingQueue<>(1000000);
|
|
|
|
|
|
|
|
|
- private static final int size = 5;
|
|
|
+ private static final int size = 10;
|
|
|
// 定义一个线程池,设置消费线程的数量
|
|
|
private static final ThreadPoolExecutor matchPoolExecutor = (ThreadPoolExecutor) Executors.newFixedThreadPool(size);
|
|
|
|