|
@@ -88,7 +88,7 @@ public class MatchVideoServiceImpl {
|
|
|
// 定义一个阻塞队列
|
|
|
private static final ArrayBlockingQueue<MatchVideo> uploadCrawlerVideoQueue = new ArrayBlockingQueue<>(1000000);
|
|
|
// 定义一个线程池,设置消费线程的数量
|
|
|
- private static final ThreadPoolExecutor uploadCrawlerVideoPoolExecutor = (ThreadPoolExecutor) Executors.newFixedThreadPool(10);
|
|
|
+ private static final ThreadPoolExecutor uploadCrawlerVideoPoolExecutor = (ThreadPoolExecutor) Executors.newFixedThreadPool(5);
|
|
|
|
|
|
@Transactional
|
|
|
public void addMatchVideo(MatchContent matchContent) {
|