浏览代码

快手头条 线程拆分

yumeng 5 年之前
父节点
当前提交
1d063ec35c

+ 4 - 4
module-ctop/src/main/java/cn/com/ctop/manage/modules/material/service/impl/MaterialUploadServiceImpl.java

@@ -13,7 +13,6 @@ import cn.com.ctop.common.module.utils.Check;
 import cn.com.ctop.common.module.utils.KuaishouInterfaceConstant;
 import cn.com.ctop.common.module.utils.LoadFileUtil;
 import cn.com.ctop.common.module.utils.PropertiesUtils;
-import cn.com.ctop.kuaishou.modules.batch.entity.KuaiShouImageGet;
 import cn.com.ctop.kuaishou.modules.batch.entity.KuaiShouVideoGet;
 import cn.com.ctop.kuaishou.modules.batch.service.IKuaiShouImageGetService;
 import cn.com.ctop.kuaishou.modules.batch.service.IKuaiShouVideoGetService;
@@ -47,7 +46,8 @@ import java.util.concurrent.Executors;
 @Slf4j
 @Service
 public class MaterialUploadServiceImpl implements IMaterialUploadService {
-    static ExecutorService executorService = Executors.newFixedThreadPool(4);
+    static ExecutorService kuaiShouExecutorService = Executors.newFixedThreadPool(5);
+    static ExecutorService touTiaoExecutorService = Executors.newFixedThreadPool(5);
     @Value("${oss.replace.replace-value}")
     private String replaceValue;
     @Value("${oss.replace.replace-old-value}")
@@ -121,7 +121,7 @@ public class MaterialUploadServiceImpl implements IMaterialUploadService {
                     if (Check.isNull(accountId)) {
                         continue;
                     }
-                    executorService.submit(new Runnable() {
+                    touTiaoExecutorService.submit(new Runnable() {
                         @Override
                         public void run() {
                             try {
@@ -193,7 +193,7 @@ public class MaterialUploadServiceImpl implements IMaterialUploadService {
                     }
                     requestJson.put("advertiser_id", accountId);
                     headerMap.put("Access-Token", ctopOauthToken.getAccessToken());
-                    executorService.submit(new Runnable() {
+                    kuaiShouExecutorService.submit(new Runnable() {
                         @Override
                         public void run() {
                             try {