cz.agents.alite.communication.channel

Class DirectCommunicationChannelAsync

java.lang.Object

cz.agents.alite.communication.channel.DefaultCommunicationChannel

cz.agents.alite.communication.channel.DefaultCommunicationChannelBroadcast

cz.agents.alite.communication.channel.DirectCommunicationChannel

cz.agents.alite.communication.channel.DirectCommunicationChannelAsync

All Implemented Interfaces:

CommunicationChannel, CommunicationChannelBroadcast

public class DirectCommunicationChannelAsync
extends DirectCommunicationChannel

Asynchronous version of DirectCommunicationChannel. Uses direct calling of the receiveMessage method using asynchronous Executors. The number of threads in the executos pool correspond to the number of processor cores Runtime.getRuntime().availableProcessors().

Author:

Jiri Vokrinek

Nested Class Summary

Nested classes/interfaces inherited from class cz.agents.alite.communication.channel.DirectCommunicationChannel

DirectCommunicationChannel.DefaultReceiverTable, DirectCommunicationChannel.ReceiverTable

Field Summary

Fields inherited from interface cz.agents.alite.communication.channel.CommunicationChannelBroadcast

BROADCAST_ADDRESS

Constructor Summary

Constructors

Constructor and Description
DirectCommunicationChannelAsync(CommunicationReceiver communicator) Deprecated.
DirectCommunicationChannelAsync(CommunicationReceiver communicator, DirectCommunicationChannel.ReceiverTable channelReceiverTable) Deprecated.
DirectCommunicationChannelAsync(CommunicationReceiver communicator, DirectCommunicationChannel.ReceiverTable channelReceiverTable, ExecutorService executorService)

Method Summary

Methods

Modifier and Type	Method and Description
protected void	callDirectReceive(CommunicationReceiver receiver, Message message) Asynchronous direct call using Executors.

Methods inherited from class cz.agents.alite.communication.channel.DirectCommunicationChannel

sendMessage

Methods inherited from class cz.agents.alite.communication.channel.DefaultCommunicationChannel

getCommunicationReceiver, receiveMessage

Methods inherited from class java.lang.Object

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

Constructor Detail

DirectCommunicationChannelAsync

@Deprecated
public DirectCommunicationChannelAsync(CommunicationReceiver communicator)
                                throws CommunicationChannelException

Deprecated.

Parameters:

communicator -

Throws:

CommunicationChannelException

DirectCommunicationChannelAsync

@Deprecated
public DirectCommunicationChannelAsync(CommunicationReceiver communicator,
                                          DirectCommunicationChannel.ReceiverTable channelReceiverTable)
                                throws CommunicationChannelException

Deprecated.

Throws:

CommunicationChannelException

DirectCommunicationChannelAsync

public DirectCommunicationChannelAsync(CommunicationReceiver communicator,
                               DirectCommunicationChannel.ReceiverTable channelReceiverTable,
                               ExecutorService executorService)
                                throws CommunicationChannelException

Throws:

CommunicationChannelException

Method Detail

callDirectReceive

protected void callDirectReceive(CommunicationReceiver receiver,
                     Message message)

Asynchronous direct call using Executors.

Overrides:

callDirectReceive in class DirectCommunicationChannel

Parameters:

receiver -

message -