jadex.commons.future

Class ReadWriteLock

java.lang.Object

jadex.commons.future.ReadWriteLock

public class ReadWriteLock
extends 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.

Constructor Summary

Constructors

Constructor and Description
ReadWriteLock()

Method Summary

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

Methods inherited from class java.lang.Object

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

Constructor Detail

ReadWriteLock

public ReadWriteLock()

Method Detail

scheduleRead

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

Schedules a read operation.

Parameters:

readcommand - The read command.

scheduleWrite

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

Schedules a write operation.

Parameters:

writecommand - The write operation.

notifyWhenFinished

public IFuture<Void> notifyWhenFinished()

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

Returns:

Future being notified.