LogCollector中ScheduledExecutorService的应用

public class ScheduleWithFixedDelayExample {

    private static ScheduledExecutorService scheduledExecutorService = Executors.newScheduledThreadPool(
        1,
        new NoneDaemonThreadFactory("testFixedDelay")
    );

    public static void main(String[] args) {
        scheduledExecutorService.scheduleWithFixedDelay(new TestTask1(), 0L, 3, TimeUnit.SECONDS);
    }
}

public class TestTask1 implements Runnable {

    @Override
    public void run() {
        System.out.println("任务开始执行时间：" + new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new Date()));
        long start = System.currentTimeMillis();
        int random = new Random().nextInt(10);
        try {
            Thread.sleep(random * 1000);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        System.out.println("任务执行花费时间：" + (System.currentTimeMillis() - start));
        System.out.println("任务结束执行时间：" + new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new Date()));
    }
}

public class NoneDaemonThreadFactory implements ThreadFactory {

    private final static AtomicInteger poolNumber = new AtomicInteger(1);

    private final AtomicInteger threadNumber = new AtomicInteger(1);

    private final ThreadGroup group;

    private final String threadNamePrefix;

    public NoneDaemonThreadFactory(String prefix) {
        SecurityManager securityManager = System.getSecurityManager();

        group = securityManager == null ? Thread.currentThread().getThreadGroup() : securityManager.getThreadGroup();

        threadNamePrefix = String.format("%s-%d-", prefix, poolNumber.getAndIncrement());
    }

    @Override
    public Thread newThread(Runnable r) {
        Thread thread = new Thread(
            group,
            r,
            threadNamePrefix + threadNumber.getAndIncrement(),
            0
        );

        if (thread.getPriority() != Thread.NORM_PRIORITY) {
            thread.setPriority(Thread.NORM_PRIORITY);
        }
        return thread;
    }
}