- NamedThreadFactory - Class in org.apache.river.thread
-
A utility to help readability of pool threads
- NamedThreadFactory(String, boolean) - Constructor for class org.apache.river.thread.NamedThreadFactory
-
- navigableMap(NavigableMap<Referrer<K>, Referrer<V>>, Ref, Ref, long, long) - Static method in class org.apache.river.concurrent.RC
-
Decorate a NavigableMap for holding Referrers so it appears as a NavigableMap
containing referents.
- navigableSet(NavigableSet<Referrer<T>>, Ref, long) - Static method in class org.apache.river.concurrent.RC
-
Decorate a NavigableSet for holding references so it appears as a NavigableSet
containing referents.
- needThread() - Method in class org.apache.river.thread.TaskManager
-
Deprecated.
Return true if a new thread should be created (ignoring maxThreads).
- newCondition() - Method in class org.apache.river.thread.ReadersWriter
-
Condition for use with writeLock()
- newSerialExecutor(BlockingQueue<Callable<T>>) - Method in class org.apache.river.thread.SynchronousExecutors
-
The ExecutorService returned, supports a subset of ExecutorService
methods, the intent of this executor is to serialize the execution
of tasks, it is up to the BlockingQueue or caller to ensure order, only
one task will execute at a time, that task will be retried if it fails,
using a back off strategy of 1, 5 and 10 seconds, followed by 1, 1 and 5
minutes thereafter forever, no other task will execute until the task
at the head of the queue is completed successfully.
- newTaskFor(Runnable, T) - Method in class org.apache.river.thread.ExtensibleExecutorService
-
- newTaskFor(Callable<T>) - Method in class org.apache.river.thread.ExtensibleExecutorService
-
- newTaskFor(Runnable, T) - Method in interface org.apache.river.thread.ExtensibleExecutorService.RunnableFutureFactory
-
Returns a RunnableFuture for the given runnable and default
value.
- newTaskFor(Callable<T>) - Method in interface org.apache.river.thread.ExtensibleExecutorService.RunnableFutureFactory
-
Returns a RunnableFuture for the given callable task.
- newThread(Runnable) - Method in class org.apache.river.thread.NamedThreadFactory
-
- NewThreadAction - Class in org.apache.river.thread
-
A PrivilegedAction for creating a new thread conveniently with an
AccessController.doPrivileged or Security.doPrivileged.
- NewThreadAction(Runnable, String, boolean) - Constructor for class org.apache.river.thread.NewThreadAction
-
Creates an action that will create a new thread in the
system thread group.
- NewThreadAction(Runnable, String, boolean, boolean) - Constructor for class org.apache.river.thread.NewThreadAction
-
Creates an action that will create a new thread.
- RC - Class in org.apache.river.concurrent
-
This class contains static methods for decorating collections
with reference capability.
- ReadersWriter - Class in org.apache.river.thread
-
An Object to control the concurrent state.
- ReadersWriter() - Constructor for class org.apache.river.thread.ReadersWriter
-
- ReadersWriter.ConcurrentLockException - Exception in org.apache.river.thread
-
InterruptedException transformed to a runtime exception.
- readerWait(Object, long) - Method in class org.apache.river.thread.ReadersWriter
-
Release a read lock, wait the given period of time or until
notified by notifier, then obtain a read lock again.
- readLock() - Method in class org.apache.river.thread.ReadersWriter
-
Obtain a read lock.
- readUnlock() - Method in class org.apache.river.thread.ReadersWriter
-
Release a read lock.
- ready() - Method in class org.apache.river.thread.ReadyState
-
Marks the service ready for use.
- ReadyState - Class in org.apache.river.thread
-
Utility class used to prevent access to a service before it has completed
its initialization or after it starts to shutdown.
- ReadyState() - Constructor for class org.apache.river.thread.ReadyState
-
- Ref - Enum in org.apache.river.concurrent
-
Ref enum represents types of references available for use in java
collection framework implementations.
- Referrer<T> - Interface in org.apache.river.concurrent
-
The public API of package private Reference implementations, it defines the equals
and hashCode contracts as well as methods identical to Reference.
- register() - Method in class org.apache.river.thread.DependencyLinker
-
- remove(Object) - Method in class org.apache.river.collection.SoftCache
-
Removes association for given key, returning value previously associated
with key, or null if none.
- remove(Object) - Method in class org.apache.river.collection.WeakIdentityMap
-
Removes association for given key, returning value previously associated
with key, or null if none.
- remove(WeakSoftTable.WeakKey, int) - Method in class org.apache.river.collection.WeakSoftTable
-
Removes and returns the index'th value associated with the specified
key.
- remove(Object) - Method in class org.apache.river.collection.WeakTable
-
Remove the object that the given key maps to.
- remove(Runnable) - Method in class org.apache.river.thread.TaskManager
-
Deprecated.
- removeBlanks() - Method in class org.apache.river.collection.WeakTable
-
Remove any blank entries from the table.
- removeIfPending(Runnable) - Method in class org.apache.river.thread.TaskManager
-
Deprecated.
Remove a task if it is pending (not active).
- roTasks - Variable in class org.apache.river.thread.TaskManager
-
Deprecated.
Read-only view of tasks
- run() - Method in class org.apache.river.thread.GetThreadPoolAction
-
- run() - Method in class org.apache.river.thread.NewThreadAction
-
- run() - Method in class org.apache.river.thread.StreamPlugThread
-
- runAfter(List, int) - Method in interface org.apache.river.thread.TaskManager.Task
-
Deprecated.
Return true if this task must be run after at least one task
in the given task list with an index less than size (size may be
less then tasks.size()).
- set(Set<Referrer<T>>, Ref, long) - Static method in class org.apache.river.concurrent.RC
-
Decorate a Set for holding references so it appears as a Set
containing referents.
- shutdown() - Method in class org.apache.river.thread.ExtensibleExecutorService
-
- shutdown() - Method in class org.apache.river.thread.ReadyState
-
Marks the service as shutting down, waiting if it is initializing,
and throwing NoSuchObjectException if it is already
shutting down.
- shutdown() - Method in class org.apache.river.thread.SynchronousExecutors
-
- shutdownNow() - Method in class org.apache.river.thread.ExtensibleExecutorService
-
- SoftCache<K,V> - Class in org.apache.river.collection
-
Map of keys to softly-referenced values which automatically removes mappings
for garbage-collected values.
- SoftCache() - Constructor for class org.apache.river.collection.SoftCache
-
- SoftValue(WeakSoftTable.WeakKey, Object) - Constructor for class org.apache.river.collection.WeakSoftTable.SoftValue
-
Creates a value for the associated key that retains a soft reference
to value.
- SoftValue(WeakSoftTable.SoftValue, ReferenceQueue) - Constructor for class org.apache.river.collection.WeakSoftTable.SoftValue
-
Creates a copy of the value registered with the queue.
- sortedMap(SortedMap<Referrer<K>, Referrer<V>>, Ref, Ref, long, long) - Static method in class org.apache.river.concurrent.RC
-
Decorate a SortedMap for holding references so it appears as a SortedMap
containing referents.
- sortedSet(SortedSet<Referrer<T>>, Ref, long) - Static method in class org.apache.river.concurrent.RC
-
Decorate a SortedSet for holding references so it appears as a SortedSet
containing referents.
- start() - Method in interface org.apache.river.api.util.Startable
-
Called after construction, this method enables objects to delay
starting threads or exporting until after construction is complete,
to allow safe publication of the service in accordance with the JMM.
- start() - Method in class org.apache.river.thread.InProgress
-
Deprecated.
Signal the start of the operation this object bounds.
- start() - Method in class org.apache.river.thread.SynchronousExecutors
-
- Startable - Interface in org.apache.river.api.util
-
Implemented by an object to enable starting threads, perform remote
export or any other activity after construction is complete, required to put
the object into an operational state.
- stop() - Method in class org.apache.river.thread.InProgress
-
Deprecated.
Signal the stop of the operation this object bounds.
- StreamPlugThread - Class in org.apache.river.thread
-
StreamPlugThread is a utility class that "plugs" two streams,
one input stream and one output stream, together by creating a thread that
repeatedly reads any data available from the input stream and writes it to
the output stream.
- StreamPlugThread(InputStream, OutputStream) - Constructor for class org.apache.river.thread.StreamPlugThread
-
- SynchronousExecutors - Class in org.apache.river.thread
-
The intent of this Executor is to share a single thread pool among tasks with
dependencies that prevent them running concurrently.
- SynchronousExecutors(ScheduledExecutorService) - Constructor for class org.apache.river.thread.SynchronousExecutors
-
- waiterNotify(Object) - Method in class org.apache.river.thread.ReadersWriter
-
Wake up any threads waiting on this notifier.
- waitUntilQuiet() - Method in class org.apache.river.thread.InProgress
-
Deprecated.
Wait if the operation bounded by this object is either started
or blocked.
- waitWhileBlocked() - Method in class org.apache.river.thread.InProgress
-
Deprecated.
Wait if the operation bounded by this object has been blocked, i.e.,
between a block and a unblock.
- waitWhileStarted() - Method in class org.apache.river.thread.InProgress
-
Deprecated.
Wait if the operation bounded by this object is in progress, i.e.,
between a start and a stop.
- WeakIdentityMap<K,V> - Class in org.apache.river.collection
-
Identity-based weak hash map.
- WeakIdentityMap() - Constructor for class org.apache.river.collection.WeakIdentityMap
-
- WeakKey(Object) - Constructor for class org.apache.river.collection.WeakSoftTable.WeakKey
-
Creates a key that holds a weak reference to the argument and
compares it using ==.
- WeakKey(WeakSoftTable.WeakKey, ReferenceQueue) - Constructor for class org.apache.river.collection.WeakSoftTable.WeakKey
-
Creates a copy of the key registered with the queue.
- WeakKeyReference<T> - Class in org.apache.river.collection
-
A weak reference to a key in a table.
- WeakKeyReference(T) - Constructor for class org.apache.river.collection.WeakKeyReference
-
Create a new WeakReference to the given key.
- WeakKeyReference(T, ReferenceQueue<T>) - Constructor for class org.apache.river.collection.WeakKeyReference
-
Create a new WeakReference to the given key, placing
the cleared reference on the specified ReferenceQueue.
- WeakSoftTable - Class in org.apache.river.collection
-
A table that maps a key containing a weak reference to one or more values
containing soft references.
- WeakSoftTable() - Constructor for class org.apache.river.collection.WeakSoftTable
-
Creates an instance of this class.
- WeakSoftTable.RemovableReference - Interface in org.apache.river.collection
-
Implemented by classes to permit copying instances into reference queues
when they are added to the table and to remove them from the table when
the references are cleared.
- WeakSoftTable.SoftValue - Class in org.apache.river.collection
-
A value that maintains a soft reference to an object.
- WeakSoftTable.WeakKey - Class in org.apache.river.collection
-
A key that maintains a weak reference to an object which should be
compared by object identity.
- WeakTable - Class in org.apache.river.collection
-
This class is designed to allow weakly held keys to weakly held
objects.
- WeakTable() - Constructor for class org.apache.river.collection.WeakTable
-
Create a new WeakTable object to maintain the maps.
- WeakTable(WeakTable.KeyGCHandler) - Constructor for class org.apache.river.collection.WeakTable
-
Create a new WeakTable object to maintain the maps that calls
back the designated object when keys are collected.
- WeakTable.KeyGCHandler - Interface in org.apache.river.collection
-
Handler for clients that need to know when a key is removed
from the table because it has been collected.
- writeLock() - Method in class org.apache.river.thread.ReadersWriter
-
Obtain a regular write lock.
- writerWait(Object, long) - Method in class org.apache.river.thread.ReadersWriter
-
- writeUnlock() - Method in class org.apache.river.thread.ReadersWriter
-
Release a (regular or priority) write lock.