jadex.commons.future

Class ReadWriteLock

java.lang.Object

jadex.commons.future.ReadWriteLock

public class ReadWriteLock
extends java.lang.Object

Locking class implementing RX-style operation: Multiple reads are allowed to be performed at the same time but write operations are exclusive. Scheduled write operations delay later read operations to prevent starvation.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
protected class	ReadWriteLock.ActionPerformedListener Listener performing post-action operations.

Field Summary

Fields

Modifier and Type	Field and Description
protected Future<java.lang.Void>	finishedfuture Future for notifying finished condition.
protected java.util.LinkedList<IResultCommand<IFuture<java.lang.Void>,java.lang.Void>>	readbacklog Backlog of read requests
protected int	reads Number of read operations in progress
protected boolean	write Flag of the write operation in progress
protected java.util.LinkedList<IResultCommand<IFuture<java.lang.Void>,java.lang.Void>>	writebacklog Backlog of write requests

Constructor Summary

Constructors

Constructor and Description
ReadWriteLock()

Method Summary

Modifier and Type	Method and Description
IFuture<java.lang.Void>	notifyWhenFinished() Returns a future notifying if/when the operations queue is currently empty.
void	scheduleRead(IResultCommand<IFuture<java.lang.Void>,java.lang.Void> readcommand) Schedules a read operation.
void	scheduleWrite(IResultCommand<IFuture<java.lang.Void>,java.lang.Void> writecommand) Schedules a write operation.

Methods inherited from class java.lang.Object

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

Field Detail

reads

protected int reads

Number of read operations in progress

write

protected boolean write

Flag of the write operation in progress

readbacklog

protected java.util.LinkedList<IResultCommand<IFuture<java.lang.Void>,java.lang.Void>> readbacklog

Backlog of read requests

writebacklog

protected java.util.LinkedList<IResultCommand<IFuture<java.lang.Void>,java.lang.Void>> writebacklog

Backlog of write requests

finishedfuture

protected Future<java.lang.Void> finishedfuture

Future for notifying finished condition.

Constructor Detail

ReadWriteLock

public ReadWriteLock()

Method Detail

scheduleRead

public void scheduleRead(IResultCommand<IFuture<java.lang.Void>,java.lang.Void> readcommand)

Schedules a read operation.

Parameters:

readcommand - The read command.

scheduleWrite

public void scheduleWrite(IResultCommand<IFuture<java.lang.Void>,java.lang.Void> writecommand)

Schedules a write operation.

Parameters:

writecommand - The write operation.

notifyWhenFinished

public IFuture<java.lang.Void> notifyWhenFinished()

Returns a future notifying if/when the operations queue is currently empty.

Returns:

Future being notified.