Package jline.lang.nodeparam

Class ForkNodeParam

java.lang.Object

jline.lang.NodeParam

jline.lang.nodeparam.ForkNodeParam

All Implemented Interfaces:

Serializable

public class ForkNodeParam
extends NodeParam

Parameter container for fork nodes in queueing networks.

This class configures fork nodes that split incoming jobs into multiple parallel tasks. Fork nodes are fundamental components in fork-join queueing models where jobs require parallel processing across multiple servers or subsystems before synchronization.

Fork node capabilities:

• Splitting jobs into parallel subtasks with configurable fan-out
• Supporting deterministic and probabilistic splitting
• Enabling parallel processing workflows
• Fork-join network modeling for multi-stage systems

Since:

1.0

See Also:

• Fork
• JoinNodeParam
• Serialized Form

Field Summary

Fields

Modifier and Type	Field	Description
double	fanOut	Fan-out ratio specifying the number of parallel tasks created per job.
DiscreteSampler[][]	fanOutDist
Matrix	fanOutLink	Variable forking levels, all (nnodes x nclasses) and indexed by DESTINATION NODE rather than link ordinal, so a relink cannot silently permute them.
Matrix	fanOutProb
Map<Integer,Matrix>	fjAuxmatrix	FJ tag augmentation: B x T auxiliary class indices per original class
Map<Integer,int[]>	fjBranchheads	FJ tag augmentation: branch head node indices per original class
List<Integer>	fjClasses	FJ tag augmentation (ModelAdapter.fjtag): original classes forked here
List<Integer>	fjJoins	FJ tag augmentation: matched join node per forked class entry

Fields inherited from class jline.lang.NodeParam

d, outlinks, patience, sdr, weightedOutlinks, weights

Constructor Summary

Constructors

Constructor	Description
ForkNodeParam()

Method Summary

Modifier and Type	Method	Description
boolean	isEmpty()	Checks if this fork parameter container is empty (no fan-out configured).

Methods inherited from class java.lang.Object

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

Field Details

fanOut

public double fanOut

Fan-out ratio specifying the number of parallel tasks created per job. Default is NaN (not configured).

fanOutLink

public Matrix fanOutLink

Variable forking levels, all (nnodes x nclasses) and indexed by DESTINATION NODE rather than link ordinal, so a relink cannot silently permute them. fanOut above stays the scalar every existing consumer reads.

fanOutLink: expected tasks sent to destination k for class r, zero on a link the class does not take. fanOutProb: probability the branch fires at all. fanOutDist: the jobs-per-link distribution, indexed [k][r] with null meaning degenerate at fanOutLink.

fanOutProb

public Matrix fanOutProb

fanOutDist

public DiscreteSampler[][] fanOutDist

fjClasses

public List<Integer> fjClasses

FJ tag augmentation (ModelAdapter.fjtag): original classes forked here

fjJoins

public List<Integer> fjJoins

FJ tag augmentation: matched join node per forked class entry

fjAuxmatrix

public Map<Integer,Matrix> fjAuxmatrix

FJ tag augmentation: B x T auxiliary class indices per original class

fjBranchheads

public Map<Integer,int[]> fjBranchheads

FJ tag augmentation: branch head node indices per original class

Constructor Details

ForkNodeParam

public ForkNodeParam()

Method Details

isEmpty

public boolean isEmpty()

Checks if this fork parameter container is empty (no fan-out configured).

Overrides:

isEmpty in class NodeParam

Returns:

true if fan-out ratio is not set (NaN), false otherwise