ScheduledExecutorService用法

ScheduledExecutorService用法

初始化

简单用法

	
public class TestTask {

    /**
     * 定时任务执行器
     */
    private ScheduledExecutorService executorService;

    /**
     * 定时任务间隔时间
     */
    private long taskTime;

    public TestTask(int threadSize, long taskTime) {
        this.beatTaskTime = beatTaskTime;
        executorService = new ScheduledThreadPoolExecutor(threadSize, (r) -> {
            Thread thread = new Thread(r);
            thread.setDaemon(true);
            thread.setName("com.wmang.service.test");
            return thread;
        });
    }

    public void initBeatTask() { 
        executorService.scheduleAtFixedRate(() -> {
              // 定时任务执行逻辑
        }, beatTaskTime,beatTaskTime, TimeUnit.MILLISECONDS);
    }
}

方法解释

schedule(Runnable command, long delay, TimeUnit un