Replace scheduleAtFixedRate when evicting with scheduleWithFixedDelay…

… for single object pool. Signed-off-by: Kenneth J. Shackleton <[email protected]>
bloomberg · Jun 25, 2024 · 5a58997 · 5a58997
1 parent 2fbda51
commit 5a58997
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/selekt-java/src/main/kotlin/com/bloomberg/selekt/pools/SingleObjectPool.kt b/selekt-java/src/main/kotlin/com/bloomberg/selekt/pools/SingleObjectPool.kt
@@ -97,6 +97,7 @@ class SingleObjectPool<K : Any, T : IPooledObject<K>>(
         }
     }?.let {
         factory.destroyObject(it)
+        attemptScheduleEviction()
     }
 
     @GuardedBy("mutex")
@@ -118,7 +119,7 @@ class SingleObjectPool<K : Any, T : IPooledObject<K>>(
         if (evictionIntervalMillis < 0L || isClosed) {
             return
         }
-        future = executor.scheduleAtFixedRate(
+        future = executor.scheduleWithFixedDelay(
             ::evict,
             evictionDelayMillis,
             evictionIntervalMillis,