|
@@ -350,7 +350,7 @@ public class CoreServiceImpl implements CoreService {
|
|
|
while (true) {
|
|
|
try {
|
|
|
// 超过 2 分钟没有数据,销毁当前线程
|
|
|
- MatchContent matchContent = matchQueue.poll(2, TimeUnit.MINUTES); // 等待最多 2 分钟
|
|
|
+ MatchContent matchContent = matchQueue.poll(60, TimeUnit.MINUTES); // 等待最多 2 分钟
|
|
|
log.info("matchContent size={}", matchQueue.size());
|
|
|
if (matchContent == null) {
|
|
|
break; // 退出当前线程
|