Executors 之 ScheduledExecutorService 代码片断

//1 thread for this pool
private final ScheduledExecutorService healthCheckScheduler = Executors.newScheduledThreadPool(1);

public void scheduleHealthCheck() {
//此处使用lambda
healthCheckScheduler.scheduleAtFixedRate(() -> {
HealthReport healthReport = createHealthReport();
latestHealth = new Health(healthReport);
if (healthReport.isAvailable()) {
String message = XXXXFormatter.toJson("health", 1);
log.info(message);
XXXClient.send(message);
}
}, 30, 900, TimeUnit.SECONDS);
log.info("Health check scheduler started with 15 minutes period");
}