java.util.concurrent.ScheduledExecutorService.scheduleAtFixedRate 在配置 12 小时后每 4-5 秒调用一次线程

Question

我有一个单例类，它在创建实例时创建一个线程。仅创建此类的一个对象，并且线程计划每 12 小时运行一次并打印给定的语句。在某些情况下，在前 12 小时之后，每 4-5 秒调用一次线程。我对为什么会发生这种情况感到困惑，因为我已将调度程序配置为每 12 小时运行一次，而不是每 4-5 秒运行一次。是否有我遗漏的配置或调度程序配置错误？

单例类，

import java.time.Instant;
import java.util.concurrent.Executors;
import java.util.concurrent.ThreadFactory;
import java.util.concurrent.TimeUnit;

public class ThreadSchedulerTest {
private static final ThreadSchedulerTest test = new ThreadSchedulerTest();
private ThreadSchedulerTest (){createThread();}

private void createThread() {

        Runnable renewer = () -> {
            System.out.println("Running ok , time is : "+ Instant.now());
        };
        Executors.newSingleThreadScheduledExecutor(new 
 ThreadSchedulerThreadFactory("thread1")).scheduleAtFixedRate(
                renewer, 0, 12, TimeUnit.HOURS);

}
static class ThreadSchedulerThreadFactory implements ThreadFactory {
    private final String name;

    public ThreadSchedulerThreadFactory(final String name) {
        this.name = name;
    }

    @Override
    public Thread newThread(Runnable r) {
        Thread thread = new Thread(r, name);
        thread.setDaemon(true);
        return thread;
    }
}
}

有人可以帮忙澄清这个问题吗？

Answer 1

如果将 TimeUnit 更改为 SECONDS 并制作实例的 Runnable 打印哈希码，您会发现更容易测试：

Runnable renewer = () -> {
    System.out.println("Running ok instance="+ThreadSchedulerTest.this.hashCode()+", time is : "+ Instant.now());
};

您每 4-5 秒重复一次的问题可能是您创建了两个 ThreadSchedulerTest 实例。上述消息修复将确认。

您提供的代码将不会运行，因为您对构造函数和成员变量进行了递归定义。因此ThreadSchedulerTest 的每个实例都会执行第二个构造函数ThreadSchedulerTest test = new ThreadSchedulerTest(); - 然后实例化一个新成员test：

new ThreadSchedulerTest()
|  Exception java.lang.StackOverflowError
|        at ThreadSchedulerTest.<init> (#5:2)

你可以修复我的这个声明 - test 是静态的，构造函数是私有的，所以只构造了一个实例：

public class ThreadSchedulerTest {
   static final ThreadSchedulerTest test = new ThreadSchedulerTest();
   private ThreadSchedulerTest () {
        createThread(); 
   }
   ...