pt.ua.concurrent

Class Channel<T>

java.lang.Object

pt.ua.concurrent.Channel<T>

public class Channel<T>
extends java.lang.Object

A simple module support a (generic) 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
Channel() Creates a new channel registering waiting threads..

Method Summary

Modifier and Type	Method and Description
void	interruptWaitingThreads() Requests the interruption all threads blocked on current channel.
void	put(T obj) Put obj in channel.
T	take() Get obj from channel.

Methods inherited from class java.lang.Object

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

Constructor Detail

Channel

public Channel()

Creates a new channel registering waiting threads..

Method Detail

put

public void put(T obj)

Put obj in channel.

Parameters:

obj - reference to the object to be transmitted

take

public T take()

Get obj from channel.

Returns:

reference to the object received

interruptWaitingThreads

public void interruptWaitingThreads()
                             throws ThreadInterruptedException

Requests the interruption all threads blocked on current channel.

Throws:

ThreadInterruptedException