final ScheduledExecutorService scheduler) {
this.dataBroker = requireNonNull(dataBroker);
LOG.info("Initializing TopologyStatsProvider service.");
- final TimerTask task = new TimerTask() {
+ scheduleTask = scheduler.scheduleAtFixedRate(new TimerTask() {
@Override
public void run() {
- synchronized (TopologyStatsProviderImpl.this) {
- updateStats();
- }
+ updateStats();
}
- };
- scheduleTask = scheduler.scheduleAtFixedRate(task, 0, updateIntervalSeconds, TimeUnit.SECONDS);
+ }, 0, updateIntervalSeconds, TimeUnit.SECONDS);
}
@Override
}
@SuppressWarnings("checkstyle:IllegalCatch")
- public synchronized void updateStats() {
+ private synchronized void updateStats() {
final TransactionChain chain = accessChain();
if (chain == null) {
// Already closed, do not bother