@@ -99,7 +99,7 @@ public class MatchVideoServiceImpl {
// 定义一个阻塞队列
- private static final ArrayBlockingQueue<MatchVideo> matchCrawlerVideoQueue = new ArrayBlockingQueue<>(1000000);
+ private static final ArrayBlockingQueue<MatchVideo> matchCrawlerVideoQueue = new ArrayBlockingQueue<>(10000000);
// 定义一个线程池,设置消费线程的数量
private static final ThreadPoolExecutor matchCrawlerVideoPoolExecutor = (ThreadPoolExecutor) Executors.newFixedThreadPool(10);