public interface VerboseBlockingBucket
Verbose API for
BlockingBucket-
Method Summary
Modifier and TypeMethodDescriptiondefault VerboseResult<Void>consume(long numTokens) Has the same semantic asBlockingBucket.consume(long)consume(long numTokens, BlockingStrategy blockingStrategy) Has the same semantic asBlockingBucket.consume(long, BlockingStrategy)default VerboseResult<Void>consumeUninterruptibly(long numTokens) Has the same semantic asBlockingBucket.consumeUninterruptibly(long)consumeUninterruptibly(long numTokens, UninterruptibleBlockingStrategy blockingStrategy) Has the same semantic asBlockingBucket.consumeUninterruptibly(long, UninterruptibleBlockingStrategy)default VerboseResult<Boolean>tryConsume(long numTokens, long maxWaitTimeNanos) Has the same semantic asBlockingBucket.tryConsume(long, long)tryConsume(long numTokens, long maxWaitTimeNanos, BlockingStrategy blockingStrategy) Has the same semantic asBlockingBucket.tryConsume(long, long, BlockingStrategy)default VerboseResult<Boolean>tryConsume(long numTokens, Duration maxWait) Has the same semantic asBlockingBucket.tryConsume(long, Duration)default VerboseResult<Boolean>tryConsume(long numTokens, Duration maxWait, BlockingStrategy blockingStrategy) Has the same semantic asBlockingBucket.tryConsume(long, Duration, BlockingStrategy)default VerboseResult<Boolean>tryConsumeUninterruptibly(long numTokens, long maxWaitTimeNanos) Has the same semantic asBlockingBucket.tryConsumeUninterruptibly(long, long)tryConsumeUninterruptibly(long numTokens, long maxWaitTimeNanos, UninterruptibleBlockingStrategy blockingStrategy) Has the same semantic asBlockingBucket.tryConsumeUninterruptibly(long, long, UninterruptibleBlockingStrategy)default VerboseResult<Boolean>tryConsumeUninterruptibly(long numTokens, Duration maxWait) Has the same semantic asBlockingBucket.tryConsumeUninterruptibly(long, Duration)default VerboseResult<Boolean>tryConsumeUninterruptibly(long numTokens, Duration maxWait, UninterruptibleBlockingStrategy blockingStrategy) Has the same semantic asBlockingBucket.tryConsumeUninterruptibly(long, Duration, UninterruptibleBlockingStrategy)
-
Method Details
-
tryConsume
VerboseResult<Boolean> tryConsume(long numTokens, long maxWaitTimeNanos, BlockingStrategy blockingStrategy) throws InterruptedException Has the same semantic asBlockingBucket.tryConsume(long, long, BlockingStrategy)- Throws:
InterruptedException
-
tryConsume
default VerboseResult<Boolean> tryConsume(long numTokens, Duration maxWait, BlockingStrategy blockingStrategy) throws InterruptedException Has the same semantic asBlockingBucket.tryConsume(long, Duration, BlockingStrategy)- Throws:
InterruptedException
-
tryConsume
default VerboseResult<Boolean> tryConsume(long numTokens, long maxWaitTimeNanos) throws InterruptedException Has the same semantic asBlockingBucket.tryConsume(long, long)- Throws:
InterruptedException
-
tryConsume
default VerboseResult<Boolean> tryConsume(long numTokens, Duration maxWait) throws InterruptedException Has the same semantic asBlockingBucket.tryConsume(long, Duration)- Throws:
InterruptedException
-
tryConsumeUninterruptibly
VerboseResult<Boolean> tryConsumeUninterruptibly(long numTokens, long maxWaitTimeNanos, UninterruptibleBlockingStrategy blockingStrategy) Has the same semantic asBlockingBucket.tryConsumeUninterruptibly(long, long, UninterruptibleBlockingStrategy) -
tryConsumeUninterruptibly
default VerboseResult<Boolean> tryConsumeUninterruptibly(long numTokens, Duration maxWait, UninterruptibleBlockingStrategy blockingStrategy) Has the same semantic asBlockingBucket.tryConsumeUninterruptibly(long, Duration, UninterruptibleBlockingStrategy) -
tryConsumeUninterruptibly
Has the same semantic asBlockingBucket.tryConsumeUninterruptibly(long, long) -
tryConsumeUninterruptibly
Has the same semantic asBlockingBucket.tryConsumeUninterruptibly(long, Duration) -
consume
VerboseResult<Void> consume(long numTokens, BlockingStrategy blockingStrategy) throws InterruptedException Has the same semantic asBlockingBucket.consume(long, BlockingStrategy)- Throws:
InterruptedException
-
consume
Has the same semantic asBlockingBucket.consume(long)- Throws:
InterruptedException
-
consumeUninterruptibly
VerboseResult<Void> consumeUninterruptibly(long numTokens, UninterruptibleBlockingStrategy blockingStrategy) Has the same semantic asBlockingBucket.consumeUninterruptibly(long, UninterruptibleBlockingStrategy) -
consumeUninterruptibly
Has the same semantic asBlockingBucket.consumeUninterruptibly(long)
-