A KanbanFlow is a network of dataflow connections made up from KanbanLinks. Links can be arranged as to form a chain (1:1), a fork (1:n), a funnel (n:1), a diamond (1:n:1) and any other acyclic directed graph by composition. Cycles are disallowed by default but can be made possible by setting the cycleAllowed property to true. All KanbanLinks in a KanbanFlow share the same PGroup. Per default this group uses a resizeable pool of daemon threads, starting with the GPars default pool size. This can be overridden by setting the pooledGroup property to a custom PGroup.
Modifiers | Name | Description |
---|---|---|
protected java.util.List<KanbanLink> |
links |
Type | Name and description |
---|---|
boolean |
cycleAllowed If adapted, this must be set before calling link() |
PGroup |
pooledGroup If adapted, this must be set before calling start() |
Constructor and description |
---|
KanbanFlow
() |
Type | Name and description |
---|---|
static groovy.lang.Closure |
inverse(groovy.lang.Closure body) Helper method that inverses the sequence of Closure parameters |
KanbanLink |
link(ProcessingNode producer) First part of the sequence link producer to consumer . |
KanbanFlow |
plus(KanbanFlow trailingFlow) Composes two flows by adding a trailing one to the current one, returning a new one. |
void |
start(int numberOfTrays) Start all KanbanLinks of this flow with so many trays |
void |
start() Start all KanbanLinks of this flow with as many trays per link as what is considered optimal |
void |
startEmpty() Start all KanbanLinks of this flow without any trays |
void |
stop() Stop all KanbanLinks of this flow |
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() |
If adapted, this must be set before calling link()
If adapted, this must be set before calling start()
Helper method that inverses the sequence of Closure parameters. *
First part of the sequence link producer to consumer
.
Composes two flows by adding a trailing one to the current one, returning a new one. KanbanLinks maintain their state beside that the last link of the current flow is linked to the first link of the trailing flow.
Start all KanbanLinks of this flow with so many trays. *
Start all KanbanLinks of this flow with as many trays per link as what is considered optimal. *
Start all KanbanLinks of this flow without any trays. *
Stop all KanbanLinks of this flow. *
Copyright © 2008–2014 Václav Pech. All Rights Reserved.