org.simbrain.network.update_actions.concurrency_tools

Class Consumer

java.lang.Object

org.simbrain.network.update_actions.concurrency_tools.Consumer

All Implemented Interfaces:

java.lang.Runnable

public class Consumer
extends java.lang.Object
implements java.lang.Runnable

The underlying runnable consumer assigned to a thread, which consumes network update tasks i.e. executes them.

Author:

Zach Tosi

Constructor Summary

Constructors

Constructor and Description
Consumer(ConcurrentBufferedUpdate.CyclicTaskQueue taskQueue, int no)

Method Summary

Modifier and Type	Method and Description
int	getId_no()
void	run() Executes tasks or waits on a cyclic barrier until a poison task is consumed which kills this consumer (sets live to false).
void	shutdown()

Methods inherited from class java.lang.Object

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

Constructor Detail

Consumer

public Consumer(ConcurrentBufferedUpdate.CyclicTaskQueue taskQueue,
                int no)

Parameters:

barrier - the cyclic barrier this consumer will wait at

taskQueue - the blocking queue this consumer will take tasks from

no - an optional ID number parameter for the consumer, used mainly for debugging, but can be used to call out an individual consumer elsewhere.

Method Detail

run

public void run()

Executes tasks or waits on a cyclic barrier until a poison task is consumed which kills this consumer (sets live to false).

Specified by:

run in interface java.lang.Runnable

getId_no

public int getId_no()

shutdown

public void shutdown()