我有一个以固定速率执行某些工作的过程:
val scheduler = Executors.newSingleThreadScheduledExecutor()
scheduler.scheduleAtFixedRate(new MigrationWorker(mytask), 1000, 50, TimeUnit.MILLISECONDS)
我的理解是,这应该运行我的任务,中间有 50 毫秒。
在运行它时,我观察到我的任务得到周期性延迟,从日志中,我看到它运行了一堆任务,然后暂停大约 30-60 秒,然后做更多。
我想知道是什么原因造成的?
谢谢,