#

zjj

18 小时以前 69ba128c58bfb9f5a79481e4997558aafc6f46c6

 src/main/java/com/zy/core/task/ShuttleExecuteScheduler.java

@@ -22,11 +22,6 @@
    private RedisUtil redisUtil;
    private int threadControlCount;

    @Scheduled(cron = "0/1 * * * * ? ")
    public void execute() {

    }

    public ShuttleExecuteScheduler(ShuttleAction shuttleAction, DeviceConfigService deviceConfigService, RedisUtil redisUtil, int threadControlCount) {
        this.shuttleAction = shuttleAction;
        this.deviceConfigService = deviceConfigService;
@@ -70,7 +65,7 @@
                            if (taskNo != 0) {
                                //存在任务需要执行
                                long startTime = System.currentTimeMillis();
                                News.info("execute {},{}", deviceConfig.getDeviceNo(), taskNo);
                                News.info("[RCS Debug] Execute {},{}", deviceConfig.getDeviceNo(), taskNo);
                                // 在循环中使用
                                boolean result = TimeoutExecutor.executeWithTimeout(
                                        () -> shuttleAction.executeWork(deviceConfig.getDeviceNo(), taskNo),
@@ -78,7 +73,7 @@
                                        TimeUnit.SECONDS
                                );
                                Thread.sleep(100);
                                News.info("execute end {},{},{}", deviceConfig.getDeviceNo(), taskNo, System.currentTimeMillis() - startTime);
                                News.info("[RCS Debug] Execute end {},{},{}", deviceConfig.getDeviceNo(), taskNo, System.currentTimeMillis() - startTime);
                            }
                        }
                    }catch (Exception e){