瀏覽代碼

多线程处理

hechunping 9 月之前
父節點
當前提交
63cf8ded71
共有 1 個文件被更改,包括 11 次插入4 次删除
  1. 11 4
      device-api-service/src/main/java/com/xy/service/factory/sim/impl/CtWingFactoryImpl.java

+ 11 - 4
device-api-service/src/main/java/com/xy/service/factory/sim/impl/CtWingFactoryImpl.java

@@ -4,6 +4,7 @@ import cn.hutool.json.JSONObject;
 import cn.hutool.json.JSONUtil;
 import com.xy.Enum.ctwing.BindTypeEnum;
 import com.xy.annotate.Factory;
+import com.xy.config.DeviceThreadPoolConfig;
 import com.xy.dto.CtWingDto;
 import com.xy.dto.CtWingVo;
 import com.xy.dto.DeviceSimPickRecordsDto;
@@ -92,10 +93,16 @@ public class CtWingFactoryImpl implements SimInfoFactory {
             CtWingVo.TrafficVo trafficVo = CtWingUtils.queryTraffic(accessNumberOrIccid);
             vo.setCurrMonthUseFlow(trafficVo.getTotalBytesCnt());
         };
-
-        queryCardMainStatus.run();
-        qryOnlineStatus.run();
-        queryTraffic.run();
+        ThreadPoolUtils.excPoll(DeviceThreadPoolConfig.DEVICE_COMMON_POLL, 3)
+                .execute(() -> {
+                    queryCardMainStatus.run();
+                })
+                .execute(() -> {
+                    qryOnlineStatus.run();
+                })
+                .execute(() -> {
+                    queryTraffic.run();
+                }).end();
         return R.ok(vo);
     }