- acquire() - Method in interface com.ibm.asyncutil.locks.AsyncSemaphore
-
- acquire(long) - Method in interface com.ibm.asyncutil.locks.AsyncSemaphore
-
Acquires the given number of permits from the semaphore, returning a stage which will complete
when all of the permits are exclusively acquired.
- acquire(long) - Method in class com.ibm.asyncutil.locks.FairAsyncSemaphore
-
Acquires the given number of permits using an acquisition-ordered fair queuing policy, i.e.
- acquireLock() - Method in interface com.ibm.asyncutil.locks.AsyncLock
-
Exclusively acquires this lock.
- acquireLock() - Method in class com.ibm.asyncutil.locks.FairAsyncLock
-
- acquireLock(T) - Method in interface com.ibm.asyncutil.locks.AsyncNamedLock
-
Acquires the lock associated with the given name.
- acquireLock(T) - Method in class com.ibm.asyncutil.locks.FairAsyncNamedLock
-
- acquireReadLock() - Method in interface com.ibm.asyncutil.locks.AsyncReadWriteLock
-
Acquires this read lock.
- acquireReadLock() - Method in class com.ibm.asyncutil.locks.FairAsyncReadWriteLock
-
- acquireReadLock(T) - Method in interface com.ibm.asyncutil.locks.AsyncNamedReadWriteLock
-
Acquires the read lock associated with the given name.
- acquireReadLock(T) - Method in class com.ibm.asyncutil.locks.FairAsyncNamedReadWriteLock
-
- acquireWriteLock() - Method in interface com.ibm.asyncutil.locks.AsyncReadWriteLock
-
Exclusively acquires this write lock.
- acquireWriteLock() - Method in class com.ibm.asyncutil.locks.FairAsyncReadWriteLock
-
- acquireWriteLock(T) - Method in interface com.ibm.asyncutil.locks.AsyncNamedReadWriteLock
-
Exclusively acquires the write lock associated with the given name.
- acquireWriteLock(T) - Method in class com.ibm.asyncutil.locks.FairAsyncNamedReadWriteLock
-
- allOf(Collection<? extends CompletionStage<?>>) - Static method in class com.ibm.asyncutil.util.Combinators
-
Given a collection of stages, returns a new
CompletionStage
that is completed when all
input stages are complete.
- AsyncCloseable - Interface in com.ibm.asyncutil.util
-
An object that may hold resources that must be explicitly released, where the release may be
performed asynchronously.
- asyncDoWhile(Function<? super T, ? extends CompletionStage<T>>, T, Predicate<? super T>) - Static method in class com.ibm.asyncutil.iteration.AsyncTrampoline
-
Repeatedly applies an asynchronous function fn
to a value until shouldContinue
returns false
, unconditionally applying fn to initialValue
on the first
iteration.
- AsyncEpoch - Interface in com.ibm.asyncutil.locks
-
A concurrency mechanism which maintains a period of activity -- an epoch -- during which
participants may successfully enter it, that later can be terminated.
- AsyncEpoch.EpochToken - Interface in com.ibm.asyncutil.locks
-
A token signifying successful entry in the active epoch.
- AsyncFunnel<T> - Class in com.ibm.asyncutil.locks
-
Enforces that a single asynchronous computation occurs at a time, allowing others to observe it.
- AsyncFunnel() - Constructor for class com.ibm.asyncutil.locks.AsyncFunnel
-
- AsyncIterator<T> - Interface in com.ibm.asyncutil.iteration
-
A mechanism for asynchronously generating and consuming values
- AsyncIterator.End - Enum in com.ibm.asyncutil.iteration
-
A marker enum that indicates there are no elements left in the iterator.
- AsyncLock - Interface in com.ibm.asyncutil.locks
-
An asynchronously acquirable mutual exclusion lock.
- AsyncLock.LockToken - Interface in com.ibm.asyncutil.locks
-
A lock token indicating that the associated lock has been exclusively acquired.
- AsyncNamedLock<T> - Interface in com.ibm.asyncutil.locks
-
A mechanism used to acquire mutual exclusion locks shared by a common name.
- AsyncNamedReadWriteLock<T> - Interface in com.ibm.asyncutil.locks
-
A mechanism used to acquire read-write locks shared by a common name.
- AsyncQueue<T> - Interface in com.ibm.asyncutil.iteration
-
An unbounded async multi-producer-single-consumer queue.
- AsyncQueues - Class in com.ibm.asyncutil.iteration
-
Methods to construct various multi-producer-single-consumer (mpsc) AsyncQueues.
- AsyncReadWriteLock - Interface in com.ibm.asyncutil.locks
-
An asynchronously acquirable read-write lock.
- AsyncReadWriteLock.ReadLockToken - Interface in com.ibm.asyncutil.locks
-
A lock token indicating that the associated lock has been acquired for reader access.
- AsyncReadWriteLock.WriteLockToken - Interface in com.ibm.asyncutil.locks
-
A lock token indicating that the associated lock has been exclusively acquired for writer
access.
- AsyncSemaphore - Interface in com.ibm.asyncutil.locks
-
An asynchronously acquirable counting semaphore
- AsyncStampedLock - Interface in com.ibm.asyncutil.locks
-
An asynchronously acquirable read-write lock which additionally provides an optimistic read mode.
- AsyncStampedLock.Stamp - Interface in com.ibm.asyncutil.locks
-
An object indicating a successful optimistic read attempt.
- AsyncTrampoline - Class in com.ibm.asyncutil.iteration
-
Static methods for asynchronous looping procedures without exhausting the stack.
- asyncWhile(Predicate<? super T>, Function<? super T, ? extends CompletionStage<T>>, T) - Static method in class com.ibm.asyncutil.iteration.AsyncTrampoline
-
Repeatedly applies an asynchronous function fn
to a value until shouldContinue
returns false
.
- asyncWhile(Supplier<? extends CompletionStage<Boolean>>) - Static method in class com.ibm.asyncutil.iteration.AsyncTrampoline
-
Repeatedly uses the function
fn
to produce a
CompletionStage
of a boolean,
stopping when then boolean is
false
.
- awaitCompletion() - Method in interface com.ibm.asyncutil.locks.AsyncEpoch
-
Waits for the epoch to complete, returning a stage that completes after the epoch has been
terminated
and all participants have exited.
- take(long) - Method in interface com.ibm.asyncutil.iteration.AsyncIterator
-
Returns an AsyncIterator that will return only the first n elements of this
AsyncIterator.
- takeWhile(Predicate<? super T>) - Method in interface com.ibm.asyncutil.iteration.AsyncIterator
-
Returns an AsyncIterator that returns elements from the backing iterator until coming across an
element that does not satisfy the predicate.
- terminate() - Method in interface com.ibm.asyncutil.iteration.AsyncQueue
-
- terminate() - Method in interface com.ibm.asyncutil.iteration.BoundedAsyncQueue
-
Terminates the queue.
- terminate() - Method in interface com.ibm.asyncutil.locks.AsyncEpoch
-
Atomically ends the active epoch, preventing new entrants from successfully entering and
returning a
CompletionStage
that triggers once all active participants have exited.
- thenApply(Function<? super T, ? extends U>) - Method in interface com.ibm.asyncutil.iteration.AsyncIterator
-
Transforms this
into a new AsyncIterator that iterates over the results of fn
applied to the outcomes of stages in this iterator when they complete normally.
- thenApplyAsync(Function<? super T, ? extends U>) - Method in interface com.ibm.asyncutil.iteration.AsyncIterator
-
Transforms this
into a new AsyncIterator that iterates over the results of fn
applied to the outcomes of stages in this iterator when they complete normally.
- thenApplyAsync(Function<? super T, ? extends U>, Executor) - Method in interface com.ibm.asyncutil.iteration.AsyncIterator
-
Transforms this
into a new AsyncIterator that iterates over the results of fn
applied to the outcomes of stages in this iterator when they complete normally.
- thenCompose(Function<? super T, ? extends CompletionStage<U>>) - Method in interface com.ibm.asyncutil.iteration.AsyncIterator
-
Transforms this
into a new AsyncIterator using the produced stages of fn
applied to the output from the stages of this
.
- thenComposeAhead(Function<? super T, ? extends CompletionStage<U>>, int) - Method in interface com.ibm.asyncutil.iteration.AsyncIterator
-
Applies a transformation to this
iterator with parallelism.
- thenComposeAsync(Function<? super T, ? extends CompletionStage<U>>) - Method in interface com.ibm.asyncutil.iteration.AsyncIterator
-
Transforms this
into a new AsyncIterator using the produced stages of fn
applied to the output from the stages of this
.
- thenComposeAsync(Function<? super T, ? extends CompletionStage<U>>, Executor) - Method in interface com.ibm.asyncutil.iteration.AsyncIterator
-
Transforms this
into a new AsyncIterator using the produced stages of fn
applied to the output from the stages of this
.
- thenComposeOrRecover(CompletionStage<T>, BiFunction<? super T, Throwable, ? extends CompletionStage<U>>) - Static method in class com.ibm.asyncutil.util.StageSupport
-
Uses the possibly exceptional result of stage
to produce a new stage.
- thenFlatten(Function<? super T, ? extends AsyncIterator<U>>) - Method in interface com.ibm.asyncutil.iteration.AsyncIterator
-
Composes fn with the stages of this
iterator to produce new AsyncIterators, and
flattens the resulting iterator of iterators.
- thenFlattenAhead(Function<? super T, ? extends CompletionStage<? extends AsyncIterator<U>>>, int) - Method in interface com.ibm.asyncutil.iteration.AsyncIterator
-
Applies a transformation and flattening to this
iterator with parallelism.
- toAsyncIterator(Flow.Publisher<? extends T>) - Static method in class com.ibm.asyncutil.flow.FlowAdapter
-
- toPublisher(AsyncIterator<? extends T>) - Static method in class com.ibm.asyncutil.flow.FlowAdapter
-
- toPublisher(Supplier<AsyncIterator<? extends T>>) - Static method in class com.ibm.asyncutil.flow.FlowAdapter
-
- toString() - Method in enum com.ibm.asyncutil.iteration.AsyncIterator.End
-
- toString() - Method in class com.ibm.asyncutil.locks.FairAsyncSemaphore
-
- tryAcquire() - Method in interface com.ibm.asyncutil.locks.AsyncSemaphore
-
- tryAcquire(long) - Method in interface com.ibm.asyncutil.locks.AsyncSemaphore
-
Attempts to acquire the given number of permits from the semaphore, returning a boolean
indicating whether all of the permits were immediately available and have been exclusively
acquired.
- tryAcquire(long) - Method in class com.ibm.asyncutil.locks.FairAsyncSemaphore
-
Attempts to acquire the given number of permits if they are immediately available.
- tryComposeWith(CompletionStage<R>, Function<? super R, ? extends CompletionStage<T>>) - Static method in class com.ibm.asyncutil.util.StageSupport
-
Performs an asynchronous function with an asynchronously acquired
AutoCloseable
,
ensuring that the resource is
closed
after the stage returned by
the function completes.
- tryComposeWith(R, Function<? super R, ? extends CompletionStage<T>>) - Static method in class com.ibm.asyncutil.util.StageSupport
-
- tryLock() - Method in interface com.ibm.asyncutil.locks.AsyncLock
-
Attempts to immediately acquire the lock, returning a populated
Optional
if the lock is
not currently held.
- tryLock() - Method in class com.ibm.asyncutil.locks.FairAsyncLock
-
- tryLock(T) - Method in interface com.ibm.asyncutil.locks.AsyncNamedLock
-
Attempts to immediately acquire the lock associated with the given name, returning a populated
Optional
if the lock is not currently held.
- tryLock(T) - Method in class com.ibm.asyncutil.locks.FairAsyncNamedLock
-
- tryOptimisticRead() - Method in interface com.ibm.asyncutil.locks.AsyncStampedLock
-
- tryOptimisticRead() - Method in class com.ibm.asyncutil.locks.FairAsyncStampedLock
-
- tryReadLock() - Method in interface com.ibm.asyncutil.locks.AsyncReadWriteLock
-
Attempts to immediately acquire the read lock, returning a populated
Optional
if the
lock is not currently held by a writer.
- tryReadLock() - Method in class com.ibm.asyncutil.locks.FairAsyncReadWriteLock
-
Attempt to immediately acquire the read lock, returning a populated
Optional
if the
lock is not currently held by a writer and there are no writers queued in waiting (i.e.
- tryReadLock(T) - Method in interface com.ibm.asyncutil.locks.AsyncNamedReadWriteLock
-
Attempts to acquire the read lock associated with the given name.
- tryReadLock(T) - Method in class com.ibm.asyncutil.locks.FairAsyncNamedReadWriteLock
-
- tryWith(CompletionStage<R>, Function<? super R, ? extends T>) - Static method in class com.ibm.asyncutil.util.StageSupport
-
Performs a function with an asynchronously acquired
auto closeable
,
ensuring that the resource is
closed
after the function runs.
- tryWith(R, Function<? super R, ? extends T>) - Static method in class com.ibm.asyncutil.util.StageSupport
-
- tryWriteLock() - Method in interface com.ibm.asyncutil.locks.AsyncReadWriteLock
-
Attempts to immediately acquire the write lock, returning a populated
Optional
if the
lock is not currently held by a writer or any readers.
- tryWriteLock() - Method in class com.ibm.asyncutil.locks.FairAsyncReadWriteLock
-
- tryWriteLock(T) - Method in interface com.ibm.asyncutil.locks.AsyncNamedReadWriteLock
-
Attempts to acquire the write lock associated with the given name.
- tryWriteLock(T) - Method in class com.ibm.asyncutil.locks.FairAsyncNamedReadWriteLock
-