worldsimulator
Class ComponentizedSimulator.ThreadSafeBundle

java.lang.Object
  |
  +--worldsimulator.ComponentizedSimulator.ThreadSafeBundle

Enclosing class:

ComponentizedSimulator

private static class ComponentizedSimulator.ThreadSafeBundle

extends Object

A multi-threaded bundle class that wraps a supplier channel for writing and a consumer queue for reading in values.

See Also:

ChannelBundle

Field Summary

private connect.SupplierChannel	channel
private util.ConsumerQueue	queue

Constructor Summary

ComponentizedSimulator.ThreadSafeBundle(connect.SupplierChannel channel, util.ConsumerQueue queue)

Method Summary

util.ConsumerQueue	getQueue()
connect.SupplierChannel	getSupplierChannel()

Methods inherited from class java.lang.Object

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

Field Detail

channel

private final connect.SupplierChannel channel

queue

private final util.ConsumerQueue queue

Constructor Detail

ComponentizedSimulator.ThreadSafeBundle

public ComponentizedSimulator.ThreadSafeBundle(connect.SupplierChannel channel,
                                               util.ConsumerQueue queue)

Method Detail

getSupplierChannel

public connect.SupplierChannel getSupplierChannel()

getQueue

public util.ConsumerQueue getQueue()