luciano/amazon-kinesis-client
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Adding safety check around stopwatches

Browse source
This commit is contained in:
Joshua Kim 2020-07-27 18:08:35 -04:00
parent 5470bc7488
commit 5a0a6c600e
1 changed files with 6 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

9
amazon-kinesis-client/src/main/java/software/amazon/kinesis/leases/LeaseCleanupManager.java
View file

@ -82,12 +82,15 @@ public class LeaseCleanupManager {
*/ */
public void start() { public void start() {
log.debug("Starting lease cleanup thread."); log.debug("Starting lease cleanup thread.");
isRunning = true;
completedLeaseStopwatch.start(); if (!isRunning) {
garbageLeaseStopwatch.start(); completedLeaseStopwatch.start();
garbageLeaseStopwatch.start();
}
deletionThreadPool.scheduleAtFixedRate(new LeaseCleanupThread(), INITIAL_DELAY, leaseCleanupIntervalMillis, deletionThreadPool.scheduleAtFixedRate(new LeaseCleanupThread(), INITIAL_DELAY, leaseCleanupIntervalMillis,
TimeUnit.MILLISECONDS); TimeUnit.MILLISECONDS);
isRunning = true;
} }
/** /**