gololang.concurrent.workers

Class Port

java.lang.Object

gololang.concurrent.workers.Port

public final class Port
extends java.lang.Object

A port is the communication endpoint to a worker function.

A port is obtained from a worker environment when spawning a function. It can then be used to send messages that will be eventually processed by the target function. Messages are being put in a first-in, first-out queue.

Constructor Summary

Constructors

Constructor and Description
Port(java.util.concurrent.ExecutorService executor, WorkerFunction function) Port constructor.

Method Summary

Modifier and Type	Method and Description
Port	send(java.lang.Object message) Sends a message to the target worker function.

Methods inherited from class java.lang.Object

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

Constructor Detail

Port

public Port(java.util.concurrent.ExecutorService executor,
            WorkerFunction function)

Port constructor.

Parameters:

executor - the executor to dispatch the asynchronous message handling jobs to.

function - the target worker function.

Method Detail

send

public Port send(java.lang.Object message)

Sends a message to the target worker function. This method returns immediately as message processing is asynchronous.

Parameters:

message - the message of any type.

Returns:

the same port object.