pt.ua.concurrent

Class Exchanger<T>

java.lang.Object

pt.ua.concurrent.CObject

pt.ua.concurrent.Exchanger<T>

All Implemented Interfaces:

InterruptibleAwaitingThreads, SyncCV

public class Exchanger<T>
extends CObject

A simple module support a (generic) exchanger (bidirectional) communication channel between two threads.

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

Author:

Miguel Oliveira e Silva (mos@ua.pt)

Constructor Summary

Constructors

Constructor and Description
Exchanger() Constructs a new Exchanger registering waiting threads.
Exchanger(boolean registerAwaitingThreads) Constructs a new Exchanger.

Method Summary

Modifier and Type	Method and Description
T	exchange(T obj) Make the argument of a thread the result of the other (exchange values between two threads).

Methods inherited from class pt.ua.concurrent.CObject

await, await, await, broadcast, interruptWaitingThreads, lockIsMine, registerAwaitingThreads, signal, syncronizedLockIsMine

Methods inherited from class java.lang.Object

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

Constructor Detail

Exchanger

public Exchanger()

Constructs a new Exchanger registering waiting threads.

Exchanger

public Exchanger(boolean registerAwaitingThreads)

Constructs a new Exchanger.

Parameters:

registerAwaitingThreads - if true, threads are registered when waiting

Method Detail

exchange

public T exchange(T obj)
           throws ThreadInterruptedException

Make the argument of a thread the result of the other (exchange values between two threads).

Parameters:

obj - reference to the object to be exchanged (send)

Returns:

reference to the object exchanged (received)

Throws:

ThreadInterruptedException