pt.ua.concurrent

Class MutexSetCV

java.lang.Object

pt.ua.concurrent.CObject

pt.ua.concurrent.MutexSetCV

All Implemented Interfaces:

InterruptibleAwaitingThreads, SyncCV

public class MutexSetCV
extends CObject
implements SyncCV

Mutex set condition variable class. This class is useful to link a condition variable to a set of mutexes (instead of one). In this way, we can safely wait for a condition that depends on more than one Mutex.

This class follows DbC(tm) methodology (Wikipedia). Where possible, contracts are implement with native's Java assert.

Version:

0.5, November 2016

Author:

Miguel Oliveira e Silva (mos@ua.pt)

Constructor Summary

Constructors

Constructor and Description
MutexSetCV(Mutex[] set) Constructs a new MutexSet with an ordered set of Mutex objects (the locking order is the array's index order).

Method Summary

Modifier and Type	Method and Description
void	await() 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.
void	broadcast() Object's nofifyAll replacement.
boolean	lockIsMine() Is lock owned by me?
void	signal() Object's nofify replacement.

Methods inherited from class pt.ua.concurrent.CObject

await, await, interruptWaitingThreads, registerAwaitingThreads, syncronizedLockIsMine

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface pt.ua.concurrent.InterruptibleAwaitingThreads

interruptWaitingThreads, registerAwaitingThreads

Constructor Detail

MutexSetCV

public MutexSetCV(Mutex[] set)

Constructs a new MutexSet with an ordered set of Mutex objects (the locking order is the array's index order).

Precondition:

set != null && set.length > 0

Parameters:

set - the ordered set of Mutex objects

Method Detail

await

public void await()

Description copied from class: 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.

Precondition:

syncronizedLockIsMine() - native lock owned by me

Specified by:

await in interface SyncCV

Overrides:

await in class CObject

signal

public void signal()

Description copied from class: CObject

Object's nofify replacement.

Precondition:

syncronizedLockIsMine() - native lock owned by me

Specified by:

signal in interface SyncCV

Overrides:

signal in class CObject

broadcast

public void broadcast()

Description copied from class: CObject

Object's nofifyAll replacement.

Precondition:

syncronizedLockIsMine() - native lock owned by me

Specified by:

broadcast in interface SyncCV

Overrides:

broadcast in class CObject

lockIsMine

public boolean lockIsMine()

Description copied from class: CObject

Is lock owned by me?

Specified by:

lockIsMine in interface SyncCV

Overrides:

lockIsMine in class CObject

Returns:

true, if lock is mine