- acquire() - Method in class pt.ua.concurrent.Semaphore
-
Acquires (decrements) the semaphore.
- active() - Method in class pt.ua.concurrent.Metronome
-
Is current metronome still active?
- activeGroup() - Method in class pt.ua.concurrent.GroupMutex
-
Current active group (unsafe operation if lock is owned
by the caller thread).
- Actor - Class in pt.ua.concurrent
-
An actor module (object-oriented approach for message passing concurrent programming).
- Actor() - Constructor for class pt.ua.concurrent.Actor
-
Constructs a new Actor (note that its attached thread is not started here).
- ajoin() - Method in class pt.ua.concurrent.CThread
-
Thread's join replacement, in which:
- the checked exception InterruptedException, is replaced by the unchecked exception ThreadInterruptedException.
- ajoin(long) - Method in class pt.ua.concurrent.CThread
-
Thread's join replacement, in which:
- the checked exception InterruptedException, is replaced by the unchecked exception ThreadInterruptedException.
- ajoin(long, int) - Method in class pt.ua.concurrent.CThread
-
Thread's join replacement, in which:
- the checked exception InterruptedException, is replaced by the unchecked exception ThreadInterruptedException.
- allDefined(Mutex[]) - Static method in class pt.ua.concurrent.AtomicLockingMutexSet
-
All the elements of the array are reference to objects.
- arun() - Method in class pt.ua.concurrent.CRunnable
-
The new thread program method (replaces run).
- arun() - Method in class pt.ua.concurrent.CThread
-
The new thread program method.
- arun() - Method in class pt.ua.concurrent.WrapRunnable
-
- AtomicLockingMutexSet - Class in pt.ua.concurrent
-
Atomic locking operation on an unordered set of mutexes.
- AtomicLockingMutexSet(Mutex[]) - Constructor for class pt.ua.concurrent.AtomicLockingMutexSet
-
Constructs a AtomicLockingMutexSet with array elements.
- await() - Method in class pt.ua.concurrent.Barrier
-
Caller will wait until the thread barrier is released, situation
in which all waiting threads are awakened.
- await() - Method in class pt.ua.concurrent.CObject
-
Object's wait replacement, in which:
- the checked exception InterruptedException, is replaced by the unchecked exception ThreadInterruptedException;
- supports the registration of waiting threads for interrupt purposes.
- await(long) - Method in class pt.ua.concurrent.CObject
-
Object's wait replacement, in which:
- the checked exception InterruptedException, is replaced by the unchecked exception ThreadInterruptedException;
- supports the registration of waiting threads for interrupt purposes;
- timeout expiration can be tested using the method's result.
- await(long, int) - Method in class pt.ua.concurrent.CObject
-
Object's wait replacement, in which:
- the checked exception InterruptedException, is replaced by the unchecked exception ThreadInterruptedException;
- supports the registration of waiting threads for interrupt purposes;
- timeout expiration can be tested using the method's result.
- await() - Method in class pt.ua.concurrent.DynamicBarrier
-
Caller will wait until all signed barrier threads are also waiting, situation
in which all of them are awakened.
- await(boolean) - Method in class pt.ua.concurrent.Event
-
Wait for a given state value.
- await() - Method in class pt.ua.concurrent.FixedBarrier
-
- await() - Method in class pt.ua.concurrent.GroupMutexComposedCV
-
- await() - Method in class pt.ua.concurrent.GroupMutexCV
-
- await() - Method in class pt.ua.concurrent.MutexCV
-
- await(long) - Method in class pt.ua.concurrent.MutexCV
-
- await() - Method in class pt.ua.concurrent.MutexSetCV
-
- await() - Method in class pt.ua.concurrent.PersistentSignal
-
- await() - Method in class pt.ua.concurrent.RWExCV
-
- await() - Method in interface pt.ua.concurrent.Signal
-
Waiting to be signaled (receiver).
- await() - Method in interface pt.ua.concurrent.SyncCV
-
Condition variable wait service.
- await() - Method in class pt.ua.concurrent.TransientSignal
-
- await() - Method in class pt.ua.concurrent.TriggeredBarrier
-
- awaitCount() - Method in class pt.ua.concurrent.Barrier
-
Caller will wait until the thread barrier is released, situation
in which all waiting threads are awakened.
- awaitCount() - Method in class pt.ua.concurrent.DynamicBarrier
-
Caller will wait until all signed barrier threads are also waiting, situation
in which all of them are awakened.
- awaitCount() - Method in class pt.ua.concurrent.FixedBarrier
-
- awaitCount() - Method in class pt.ua.concurrent.TriggeredBarrier
-
- changePriority(GroupMutex.Priority) - Method in class pt.ua.concurrent.GroupMutex
-
Change current lock priority.
- changePriority(RWEx.Priority) - Method in class pt.ua.concurrent.RWEx
-
Change current priority.
- changeToReader() - Method in class pt.ua.concurrent.RWEx
-
Change from a writer lock to a reader lock.
- Channel<T> - Class in pt.ua.concurrent
-
A simple module support a (generic) communication channel between two threads.
- Channel() - Constructor for class pt.ua.concurrent.Channel
-
Creates a new channel registering waiting threads..
- CObject - Class in pt.ua.concurrent
-
A replacement for Object to ease and augment the usage of concurrent related methods.
- CObject() - Constructor for class pt.ua.concurrent.CObject
-
Constructor of an object without registering waiting threads in await service.
- CObject(boolean) - Constructor for class pt.ua.concurrent.CObject
-
Constructor of an object.
- colors - Static variable in class pt.ua.concurrent.Console
-
- Console - Class in pt.ua.concurrent
-
System output related static utilities (supporting colors).
- Console() - Constructor for class pt.ua.concurrent.Console
-
- count() - Method in class pt.ua.concurrent.Barrier
-
Number of times the barrier was released (to be more precise: the remainder
of the integer division for 2^63)
- CROSSED_OUT - Static variable in class pt.ua.concurrent.Console
-
- CRunnable - Class in pt.ua.concurrent
-
A replacement for Runnable to handle exceptions (and other details).
- CRunnable() - Constructor for class pt.ua.concurrent.CRunnable
-
- CThread - Class in pt.ua.concurrent
-
Thread related static utilities.
- CThread() - Constructor for class pt.ua.concurrent.CThread
-
Constructor of a thread (direct replacement of Thread's constructor).
- CThread(Runnable) - Constructor for class pt.ua.concurrent.CThread
-
Constructor of a thread (direct replacement of Thread's constructor).
- CThread(String) - Constructor for class pt.ua.concurrent.CThread
-
Constructor of a thread (direct replacement of Thread's constructor).
- CThread(ThreadGroup, String) - Constructor for class pt.ua.concurrent.CThread
-
Constructor of a thread (direct replacement of Thread's constructor).
- CThread(Runnable, String) - Constructor for class pt.ua.concurrent.CThread
-
Constructor of a thread (direct replacement of Thread's constructor).
- CThread(ThreadGroup, Runnable) - Constructor for class pt.ua.concurrent.CThread
-
Constructor of a thread (direct replacement of Thread's constructor).
- CThread(ThreadGroup, Runnable, String) - Constructor for class pt.ua.concurrent.CThread
-
Constructor of a thread (direct replacement of Thread's constructor).
- CThread(ThreadGroup, Runnable, String, long) - Constructor for class pt.ua.concurrent.CThread
-
Constructor of a thread (direct replacement of Thread's constructor).
- CThread(CRunnable) - Constructor for class pt.ua.concurrent.CThread
-
Constructor of a thread (direct replacement of Thread's constructor).
- CThread(CRunnable, String) - Constructor for class pt.ua.concurrent.CThread
-
Constructor of a thread (direct replacement of Thread's constructor).
- CThread(ThreadGroup, CRunnable) - Constructor for class pt.ua.concurrent.CThread
-
Constructor of a thread (direct replacement of Thread's constructor).
- CThread(ThreadGroup, CRunnable, String) - Constructor for class pt.ua.concurrent.CThread
-
Constructor of a thread (direct replacement of Thread's constructor).
- CThread(ThreadGroup, CRunnable, String, long) - Constructor for class pt.ua.concurrent.CThread
-
Constructor of a thread (direct replacement of Thread's constructor).
- CThread.TerminationPolicy - Enum in pt.ua.concurrent
-
Termination policy for thread created through current CThread's object.
- currentThread() - Static method in class pt.ua.concurrent.CThread
-
Current thread.
- currentThreadID() - Static method in class pt.ua.concurrent.CThread
-
Current thread id.
- CYAN - Static variable in class pt.ua.concurrent.Console
-
- readerLockIsMine() - Method in class pt.ua.concurrent.RWEx
-
Is reader lock owned by me?
- recoverState(SyncState) - Method in class pt.ua.concurrent.AtomicLockingMutexSet
-
- recoverState(SyncState) - Method in class pt.ua.concurrent.GroupMutex
-
- recoverState(SyncState) - Method in class pt.ua.concurrent.Mutex
-
- recoverState(SyncState) - Method in class pt.ua.concurrent.RWEx
-
- recoverState(SyncState) - Method in interface pt.ua.concurrent.Sync
-
Recover Sync state.
- recursive() - Method in class pt.ua.concurrent.Mutex
-
Is current mutex recursive?
- recursive() - Method in class pt.ua.concurrent.RWEx
-
Is current rwex recursive?
- RED - Static variable in class pt.ua.concurrent.Console
-
- registerAwaitingThreads() - Method in class pt.ua.concurrent.CObject
-
Are threads registered when waiting (in await)?
- registerAwaitingThreads() - Method in interface pt.ua.concurrent.InterruptibleAwaitingThreads
-
Are threads registered when waiting (in await)?
- release() - Method in class pt.ua.concurrent.BoundedSemaphore
-
Releases the semaphore.
- release() - Method in class pt.ua.concurrent.ExternalBarrier
-
Release barrier (regardless of the number of waiting threads).
- release() - Method in class pt.ua.concurrent.Semaphore
-
Releases (increments) the semaphore.
- release() - Method in class pt.ua.concurrent.TriggeredBarrier
-
- reset() - Method in class pt.ua.concurrent.Event
-
Reset the event state (false).
- resetColor() - Static method in class pt.ua.concurrent.Console
-
- result() - Method in class pt.ua.concurrent.Future
-
The result of the actor's function attached to this future.
- run() - Method in class pt.ua.concurrent.Actor
-
The actor's message handling routine.
- run() - Method in class pt.ua.concurrent.CRunnable
-
Default run method is simply to call arun.
- run() - Method in class pt.ua.concurrent.CThread
-
Replacement of default run method to correctly handle exceptions,
and also to register thread execution start time.
- rwe() - Method in class pt.ua.concurrent.RWExCV
-
- RWEx - Class in pt.ua.concurrent
-
Readers-writer exclusion class.
- RWEx() - Constructor for class pt.ua.concurrent.RWEx
-
Constructs a new non-recursive RWEx with WRITER priority and registering waiting threads.
- RWEx(boolean, boolean) - Constructor for class pt.ua.concurrent.RWEx
-
Constructs a new RWEx with WRITER priority.
- RWEx(RWEx.Priority) - Constructor for class pt.ua.concurrent.RWEx
-
Constructs a new non-recursive RWEx registering waiting threads.
- RWEx(RWEx.Priority, boolean) - Constructor for class pt.ua.concurrent.RWEx
-
Constructs a new non-recursive RWEx.
- RWEx(RWEx.Priority, boolean, boolean) - Constructor for class pt.ua.concurrent.RWEx
-
Constructs a new RWEx.
- RWEx.Priority - Enum in pt.ua.concurrent
-
Locking priority choices:
WRITER: priority to writers (a waiting writer prevents new readers from getting the lock);
READERS: priority to readers (a waiting reader prevents new writers from getting the lock);
TIME_OF_ARRIVAL: priority ordered by decreasing waiting time (not yet implemented!).
- RWExCV - Class in pt.ua.concurrent
-
Readers-writer exclusion condition variable class.
- Semaphore - Class in pt.ua.concurrent
-
A standard counting semaphore class.
- Semaphore() - Constructor for class pt.ua.concurrent.Semaphore
-
Creates a semaphore initialized with a zero counter and registering waiting threads.
- Semaphore(int) - Constructor for class pt.ua.concurrent.Semaphore
-
Creates a semaphore initialized with a given counter and registering waiting threads.
- Semaphore(int, boolean) - Constructor for class pt.ua.concurrent.Semaphore
-
Creates a semaphore initialized with a given counter.
- send() - Method in class pt.ua.concurrent.PersistentSignal
-
- send() - Method in interface pt.ua.concurrent.Signal
-
Signaling (sender).
- send() - Method in class pt.ua.concurrent.TransientSignal
-
- set() - Method in class pt.ua.concurrent.Event
-
Set the event state (true).
- setColor(String) - Static method in class pt.ua.concurrent.Console
-
- setResult(T) - Method in class pt.ua.concurrent.Future
-
Sets the result of the actor's function attached to this future.
- setSize(int) - Method in class pt.ua.concurrent.FixedBarrier
-
Define a new size for the barrier.
- setTerminationPolicy(CThread.TerminationPolicy) - Method in class pt.ua.concurrent.CThread
-
Define the thread's termination policy.
- signal() - Method in class pt.ua.concurrent.CObject
-
Object's nofify replacement.
- signal() - Method in class pt.ua.concurrent.GroupMutexComposedCV
-
- signal() - Method in class pt.ua.concurrent.GroupMutexCV
-
- signal() - Method in class pt.ua.concurrent.MutexCV
-
- signal() - Method in class pt.ua.concurrent.MutexSetCV
-
- signal() - Method in class pt.ua.concurrent.RWExCV
-
- Signal - Interface in pt.ua.concurrent
-
A simple signal abstraction module.
- signal() - Method in interface pt.ua.concurrent.SyncCV
-
Condition variable signal (notify) service.
- signIn() - Method in class pt.ua.concurrent.DynamicBarrier
-
Add signature of current thread in the barrier.
- signOut() - Method in class pt.ua.concurrent.DynamicBarrier
-
Remove signature of current thread in the barrier.
- size() - Method in class pt.ua.concurrent.DynamicBarrier
-
- size() - Method in class pt.ua.concurrent.FixedBarrier
-
- size() - Method in class pt.ua.concurrent.InternalBarrier
-
Number of threads defined for the barrier.
- sourceException() - Method in class pt.ua.concurrent.CThread
-
Get the exception responsible for the thread's failure.
- start(CThread.TerminationPolicy) - Method in class pt.ua.concurrent.CThread
-
A start method imposing an explicit termination policy.
- start() - Method in class pt.ua.concurrent.CThread
-
Replacement of default start method (required to properly implement termination policy).
- started() - Method in class pt.ua.concurrent.CThread
-
Was request to start thread issued?
- startTime() - Method in class pt.ua.concurrent.CThread
-
Time instance at which the thread has started execution.
- startTimeRegistered() - Method in class pt.ua.concurrent.CThread
-
Has thread start time been registered?
- state() - Method in class pt.ua.concurrent.SyncState
-
- stateMatches(boolean) - Method in class pt.ua.concurrent.Event
-
Does current state matches argument?
This method should be used with utmost care, because its result,
depending on the event's usage, might change immediately after
it has been called (race condition).
- sync() - Method in class pt.ua.concurrent.Metronome
-
Caller will wait until the next metronome tick.
- Sync - Interface in pt.ua.concurrent
-
Java's interface for locks.
- SyncCV - Interface in pt.ua.concurrent
-
Java's interface for condition variables.
- syncronizedLockIsMine() - Method in class pt.ua.concurrent.CObject
-
Is native (synchronized) lock owned by me?
- SyncState - Class in pt.ua.concurrent
-
- take() - Method in class pt.ua.concurrent.Channel
-
Get obj from channel.
- terminate() - Method in class pt.ua.concurrent.Actor
-
Terminate te execution of actor.
- terminate() - Method in class pt.ua.concurrent.Metronome
-
Terminate current metronome.
- terminated() - Method in class pt.ua.concurrent.Actor
-
Is the actor terminated?
- terminated() - Method in class pt.ua.concurrent.CThread
-
Thread terminated?
- terminationPolicy() - Method in class pt.ua.concurrent.CThread
-
Current CThread object's termination policy.
- ThreadInterruptedException - Exception in pt.ua.concurrent
-
InterruptedException unchecked exception replacement.
- ThreadInterruptedException() - Constructor for exception pt.ua.concurrent.ThreadInterruptedException
-
- ThreadInterruptedException(Throwable) - Constructor for exception pt.ua.concurrent.ThreadInterruptedException
-
- toggle() - Method in class pt.ua.concurrent.Event
-
Toggle the event state.
- TransientSignal - Class in pt.ua.concurrent
-
A transient signal module (signals thrown away if no one is waiting).
- TransientSignal() - Constructor for class pt.ua.concurrent.TransientSignal
-
Constructs a new TransientSignal registering waiting threads.
- TransientSignal(boolean) - Constructor for class pt.ua.concurrent.TransientSignal
-
Constructs a new TransientSignal.
- TriggeredBarrier - Class in pt.ua.concurrent
-
An externally triggered thread barrier class.
In this type of barrier, the barrier is released by an externally usable (public) method (
release).
- TriggeredBarrier() - Constructor for class pt.ua.concurrent.TriggeredBarrier
-
Constructs a new triggered barrier registering waiting threads.
- TriggeredBarrier(boolean) - Constructor for class pt.ua.concurrent.TriggeredBarrier
-
Constructs a new triggered size barrier.
- trylock() - Method in class pt.ua.concurrent.AtomicLockingMutexSet
-
Try to lock mutex (without waiting).
- tryLock(int) - Method in class pt.ua.concurrent.GroupMutex
-
Attempt to lock a group (no waiting involved).
- trylock() - Method in class pt.ua.concurrent.Mutex
-
Try to lock mutex (without waiting).
- trylockReader() - Method in class pt.ua.concurrent.RWEx
-
Try to lock as a reader (without waiting).
- trylockWriter() - Method in class pt.ua.concurrent.RWEx
-
Try to lock as a writer (without waiting).
- tryToChangeToWriter() - Method in class pt.ua.concurrent.RWEx
-
Attempts to change from a reader lock to a writer lock.