Package co.paralleluniverse.strands.channels

Interface FloatReceivePort

All Superinterfaces:

java.lang.AutoCloseable, Port<java.lang.Float>, PortAutoCloseable, ReceivePort<java.lang.Float>

All Known Subinterfaces:

FloatChannel

All Known Implementing Classes:

QueueFloatChannel, TickerChannelConsumer.TickerChannelFloatConsumer

public interface FloatReceivePort
extends ReceivePort<java.lang.Float>

A primitive float channel's consumer-side interface. All methods of this interface must only be called by the channel's owner.

Nested Class Summary

Nested classes/interfaces inherited from interface co.paralleluniverse.strands.channels.ReceivePort

ReceivePort.EOFException

Method Summary

Modifier and Type	Method	Description
boolean	hasMessage()	Tests whether a value is pending in the channel.
float	receiveFloat()	Retrieves a message from the channels, possibly blocking until one becomes available.
float	receiveFloat(long timeout, java.util.concurrent.TimeUnit unit)	Retrieves a message from the channels, possibly blocking until one becomes available, but no longer than the specified timeout.
float	receiveFloat(Timeout timeout)	Retrieves a message from the channels, possibly blocking until one becomes available, but no longer than the specified timeout.

Methods inherited from interface co.paralleluniverse.strands.channels.PortAutoCloseable

close, isClosed

Methods inherited from interface co.paralleluniverse.strands.channels.ReceivePort

receive, receive, receive, tryReceive

Method Detail

receiveFloat

float receiveFloat()
            throws SuspendExecution,
                   java.lang.InterruptedException,
                   ReceivePort.EOFException

Retrieves a message from the channels, possibly blocking until one becomes available. If the channel has been closed and no more messages await, this method throws an ReceivePort.EOFException.

Returns:

a message.

Throws:

ReceivePort.EOFException - if the channel has been closed and no more messages await

java.lang.InterruptedException

SuspendExecution

receiveFloat

float receiveFloat(long timeout,
                   java.util.concurrent.TimeUnit unit)
            throws SuspendExecution,
                   java.lang.InterruptedException,
                   java.util.concurrent.TimeoutException,
                   ReceivePort.EOFException

Retrieves a message from the channels, possibly blocking until one becomes available, but no longer than the specified timeout. If the channel has been closed and no more messages await, this method throws an ReceivePort.EOFException.

Parameters:

timeout - the maximum duration to block waiting for a message.

unit - the time unit of the timeout.

Returns:

a message. (see PortAutoCloseable.isClosed()), or if the timeout has expired.

Throws:

java.util.concurrent.TimeoutException - if the timeout has expired

ReceivePort.EOFException - if the channel has been closed and no more messages await

java.lang.InterruptedException

SuspendExecution

receiveFloat

float receiveFloat(Timeout timeout)
            throws SuspendExecution,
                   java.lang.InterruptedException,
                   java.util.concurrent.TimeoutException,
                   ReceivePort.EOFException

Retrieves a message from the channels, possibly blocking until one becomes available, but no longer than the specified timeout. If the channel has been closed and no more messages await, this method throws an ReceivePort.EOFException.

Parameters:

timeout - the method will not block for longer than the amount remaining in the Timeout

Returns:

a message. (see PortAutoCloseable.isClosed()), or if the timeout has expired.

Throws:

java.util.concurrent.TimeoutException - if the timeout has expired

ReceivePort.EOFException - if the channel has been closed and no more messages await

java.lang.InterruptedException

SuspendExecution

hasMessage

boolean hasMessage()

Tests whether a value is pending in the channel. If it is, the next call to receiveDouble is guaranteed not to block.

Returns:

true if a value is waiting in the channel; false otherwise.