(fix) lambda

sofastack · Jul 21, 2019 · 3367394 · 3367394
1 parent da0bbee
commit 3367394
Showing 1 changed file with 2 additions and 3 deletions.
diff --git a/jraft-core/src/main/java/com/alipay/sofa/jraft/storage/log/RocksDBSegmentLogStorage.java b/jraft-core/src/main/java/com/alipay/sofa/jraft/storage/log/RocksDBSegmentLogStorage.java
@@ -279,9 +279,8 @@ private String getCheckpointFileName(final Checkpoint checkpoint) {
     private void startCheckpointTask() {
         this.checkpointExecutor = Executors
                 .newSingleThreadScheduledExecutor(new NamedThreadFactory(getServiceName() + "-Checkpoint-Thread-", true));
-        this.checkpointExecutor.scheduleAtFixedRate(() -> {
-            doCheckpoint();
-        }, DEFAULT_CHECKPOINT_INTERVAL_MS, DEFAULT_CHECKPOINT_INTERVAL_MS, TimeUnit.MILLISECONDS);
+        this.checkpointExecutor.scheduleAtFixedRate(this::doCheckpoint,
+                DEFAULT_CHECKPOINT_INTERVAL_MS, DEFAULT_CHECKPOINT_INTERVAL_MS, TimeUnit.MILLISECONDS);
         LOG.info("{} started checkpoint task.", getServiceName());
     }