uni/src/main/java/com/scbfkj/uni/system/ScheduleTask.java

package com.scbfkj.uni.system;

import com.scbfkj.uni.service.DataProcessService;

import java.util.HashMap;

public class ScheduleTask implements Runnable {


    private String id; // 服务ID

    public String getId() {
        return id;
    }

    Integer loopCount = 0;
    int count = 0;

    private DataProcessService service;


    /**
     * @param id 任务ID
     */
    public ScheduleTask(String id) {
        this.id = id;
    }

    public ScheduleTask(String id, Integer loopCount) {
        this.id = id;
        this.loopCount = loopCount;
    }

    @Override
    public void run() {

        do {
            count++;
            try {
                service.process(new HashMap<>());
            } catch (Exception e) {
                throw new RuntimeException(e);
            }
        } while (loopCount > count);
    }


}