Simplify usage of Bucket4j via using new API method consumeIgnoringRateLimits which was added in the version 4.8.0

Author: vladimir-bukhtoyarov

extended/pom.xml

@@ -140,6 +140,6 @@
  <maven.compiler.source>${java.version}</maven.compiler.source>
  <maven.compiler.target>${java.version}</maven.compiler.target>
  <slf4jVersion>1.7.7</slf4jVersion>
- <bucket4jVersion>4.4.1</bucket4jVersion>
+ <bucket4jVersion>4.8.0</bucket4jVersion>
  </properties>
 </project>

extended/src/main/java/io/kubernetes/client/extended/workqueue/ratelimiter/BucketRateLimiter.java

@@ -6,9 +6,6 @@
 import io.github.bucket4j.Refill;
 import io.github.bucket4j.local.SynchronizationStrategy;
 import java.time.Duration;
-import java.util.concurrent.ScheduledFuture;
-import java.util.concurrent.ScheduledThreadPoolExecutor;
-import java.util.concurrent.TimeUnit;
 
 /** A light-weight token bucket implementation for RateLimiter. */
 public class BucketRateLimiter<T> implements RateLimiter<T> {
@@ -31,9 +28,8 @@ public BucketRateLimiter(long capacity, long tokensGeneratedInPeriod, Duration p
 
  @Override
  public Duration when(T item) {
- DelayGetter delayGetter = new DelayGetter();
- bucket.asAsyncScheduler().consume(1, delayGetter).complete(null);
- return delayGetter.getDelay();
+ long overdraftNanos = bucket.consumeIgnoringRateLimits(1);
+ return Duration.ofNanos(overdraftNanos);
  }
 
  @Override
@@ -43,22 +39,4 @@ public void forget(T item) {}
  public int numRequeues(T item) {
  return 0;
  }
-
- private class DelayGetter extends ScheduledThreadPoolExecutor {
- private Duration delay = Duration.ZERO;
-
- @Override
- public ScheduledFuture<?> schedule(Runnable command, long delay, TimeUnit unit) {
- this.delay = Duration.ofNanos(unit.toNanos(delay));
- return null;
- }
-
- private DelayGetter() {
- super(0);
- }
-
- private Duration getDelay() {
- return delay;
- }
- }
 }