A KanbanLink is the simplest possible producer-consumer pair in a kanban-like scenario as described in

• • Field Summary

    Fields 

    Modifiers	Name	Description
    protected DataflowProcessor	consumer
    protected DataflowQueue	downstream
    protected DataflowProcessor	producer
    protected DataflowQueue	upstream

  • Properties Summary

    Properties 

    Type	Name and description
    ProcessingNode	consumerSpec
    KanbanFlow	flow
    ProcessingNode	producerSpec

  • Constructor Summary

    Constructors 

    Constructor and description
    KanbanLink ()

  • Methods Summary

    Methods 

    Type	Name and description
    java.lang.Object	addOptimalNumberOfTrays() Put as many trays into the system as there are processing units.
    void	addTray() Putting another tray into system by adding an empty one to the upstream
    protected boolean	consumerAlreadyStarted()
    int	getId() The index of this link in its flow
    protected boolean	producerAlreadyStarted()
    void	removeTray() Removing a tray from the system by fetching the next one from the upstream
    void	start() Construct and start the operators if not already started.
    void	stop() Immediately terminating all producers and consumers
    KanbanLink	to(ProcessingNode consumerSpec) Second part of the sequence link producer to consumer.

  • Inherited Methods Summary

    Inherited Methods 

    Methods inherited from class	Name
    class java.lang.Object	java.lang.Object#wait(), java.lang.Object#wait(long, int), java.lang.Object#wait(long), java.lang.Object#equals(java.lang.Object), java.lang.Object#toString(), java.lang.Object#hashCode(), java.lang.Object#getClass(), java.lang.Object#notify(), java.lang.Object#notifyAll()