|
@@ -415,7 +415,7 @@ public class CoreServiceImpl implements CoreService {
|
|
|
CountDownLatch latch = new CountDownLatch(threadSize);
|
|
CountDownLatch latch = new CountDownLatch(threadSize);
|
|
|
// 启动消费者线程
|
|
// 启动消费者线程
|
|
|
for (int i = 0; i < threadSize; i++) {
|
|
for (int i = 0; i < threadSize; i++) {
|
|
|
- matchPoolExecutor.submit(new Thread(() -> {
|
|
|
|
|
|
|
+ corePoolExecutor.submit(new Thread(() -> {
|
|
|
log.info("启动核心操作线程");
|
|
log.info("启动核心操作线程");
|
|
|
while (true) {
|
|
while (true) {
|
|
|
try {
|
|
try {
|