Minor cleanup before release

ben-manes · Apr 3, 2016 · ceea49e · ceea49e
1 parent d40f0a1
commit ceea49e
Showing 1 changed file with 3 additions and 6 deletions.
diff --git a/caffeine/src/main/java/com/github/benmanes/caffeine/cache/BoundedLocalCache.java b/caffeine/src/main/java/com/github/benmanes/caffeine/cache/BoundedLocalCache.java
@@ -2852,8 +2852,7 @@ final class BoundedExpireAfterAccess implements Expiration<K, V> {
       @Override public void setExpiresAfter(long duration, TimeUnit unit) {
         Caffeine.requireArgument(duration >= 0);
         cache.setExpiresAfterAccessNanos(unit.toNanos(duration));
-        cache.drainBuffersTask.reinitialize();
-        cache.executor().execute(cache.drainBuffersTask);
+        cache.scheduleAfterWrite();
       }
       @Override public Map<K, V> oldest(int limit) {
         return cache.expireAfterAcessOrder(limit, transformer, true);
@@ -2881,8 +2880,7 @@ final class BoundedExpireAfterWrite implements Expiration<K, V> {
       @Override public void setExpiresAfter(long duration, TimeUnit unit) {
         Caffeine.requireArgument(duration >= 0);
         cache.setExpiresAfterWriteNanos(unit.toNanos(duration));
-        cache.drainBuffersTask.reinitialize();
-        cache.executor().execute(cache.drainBuffersTask);
+        cache.scheduleAfterWrite();
       }
       @Override public Map<K, V> oldest(int limit) {
         return cache.expireAfterWriteOrder(limit, transformer, true);
@@ -2910,8 +2908,7 @@ final class BoundedRefreshAfterWrite implements Expiration<K, V> {
       @Override public void setExpiresAfter(long duration, TimeUnit unit) {
         Caffeine.requireArgument(duration >= 0);
         cache.setRefreshAfterWriteNanos(unit.toNanos(duration));
-        cache.drainBuffersTask.reinitialize();
-        cache.executor().execute(cache.drainBuffersTask);
+        cache.scheduleAfterWrite();
       }
       @SuppressWarnings("PMD.SimplifiedTernary") // false positive (#1424)
       @Override public Map<K, V> oldest(int limit) {