Package | Description |
---|---|
desmoj.extensions.crossbar |
A higher-level construct to facilitate indirect process synchronization based on exchanging massages.
|
Modifier and Type | Method and Description |
---|---|
CrossbarMessage |
MessageChannel.waitForMessage()
Wait for a
CrossbarMessage on this channel, thereby passivating
the current process. |
CrossbarMessage |
MessageCrossbar.waitForMessage(java.util.List<MessageChannel<T>> channelsToWaitOn)
Wait for a
CrossbarMessage on the specified message channels,
thereby passivating the current process. |
CrossbarMessage |
MessageCrossbar.waitForMessage(java.util.List<MessageChannel<T>> channelsToWaitOn,
TimeInstant waitUntil)
Wait for a
CrossbarMessage on the specified message channels,
thereby passivating the current process. |
CrossbarMessage |
MessageCrossbar.waitForMessage(java.util.List<MessageChannel<T>> channelsToWaitOn,
TimeSpan maxWaitTime)
Wait for a
CrossbarMessage on the specified message channels,
thereby passivating the current process. |
CrossbarMessage |
MessageChannel.waitForMessage(TimeInstant waitUntil)
Wait for a
CrossbarMessage on this channel, thereby passivating
the current process. |
CrossbarMessage |
MessageChannel.waitForMessage(TimeSpan maxWaitTime)
Wait for a
CrossbarMessage on this channel, thereby passivating
the current process. |
Modifier and Type | Method and Description |
---|---|
void |
MessageChannel.send(CrossbarMessage message)
Sends the given
CrossbarMessage to the channel, thereby
activating all processes that are waiting on the channel. |
void |
MessageCrossbar.sendMessage(CrossbarMessage message,
java.util.List<MessageChannel<T>> channelsToSendTo)
Sends the given
CrossbarMessage to the specified message
channels, thereby activating all processes that are waiting on these
channel. |