java - 在 Java 8 中生成具有无限循环的线程的最佳方法是什么？

Question

我有一个方法需要每 n 秒调用一次。在过去的 Java 时代，我会做这样的事情:

Runnable task = () -> {

  while (!updater.isInterrupted()) {
       //some Task
    } catch (InterruptedException e) {}
   }
};
Thread updater = new Thread(task);
updater.start();

但这显然是个坏主意。如果我想停止线程，我需要调用 updater.interrupt() 并依赖异常处理，这实际上不是为这个东西做的。

所以我想有一些奇特的"new"Java8 方法可以做到这一点。我已经看到了这个:

public class TestSchedularService {
 long sleep = 500;

 @Test
 public void testLoop2() throws Exception {
ScheduledExecutorService executor = Executors.newSingleThreadScheduledExecutor();
ScheduledFuture future = executor.scheduleWithFixedDelay(new PollingService(), 0, sleep,TimeUnit.MILLISECONDS);
Thread.sleep(2 * sleep);
future.cancel(false);
executor.shutdown();
 }
}

class PollingService implements Runnable {
 private int count = 0;
public void run() {
System.out.println("iteration :" + (count++));
 }
}

但它似乎在每次调用时都创建了一个 PollingService 实例，这似乎很糟糕。那么每 n 秒调用一次方法的最有效和“最新”的方法是什么？

Answer 1

使用 ScheduledExecutorService 是正确的方法。它不会创建 PollingService 的新实例，您创建它并且执行程序一直在同一实例上调用 run 直到您取消 Future.