ports/com.group7.policies.fork/LeastFullForkPolicy

LeastFullForkPolicy

class LeastFullForkPolicy<T>(tags: Iterable<OutputTag<Container<*>>> = generateSequence { newDynamicOutputTag { it.walkDownstream().filterIsInstance<Container<*>>().first() } } .asIterable()) : ForkPolicy<T>

Fork policy that routes each entity to the destination with the least occupancy. Helps balance load across multiple branches.

Parameters

the type of entities being routed

Constructors

LeastFullForkPolicy

constructor(tags: Iterable<OutputTag<Container<*>>> = generateSequence { newDynamicOutputTag { it.walkDownstream().filterIsInstance<Container<*>>().first() } } .asIterable())

Functions

allClosed

open override fun allClosed(): Boolean

Checks if all destination channels are closed.

initialize

context(_: Simulator)
open override fun initialize(source: PushInputChannel<T>, destinations: List<PushOutputChannel<T>>)

Initializes the policy with the source and destination channels. Sets up initial state and event listeners for channel open/close events.

onChannelClose

open override fun onChannelClose(channel: PushOutputChannel<T>)

Called when a destination channel closes.

onChannelOpen

open override fun onChannelOpen(channel: PushOutputChannel<T>)

Called when a destination channel opens.

selectChannel

open override fun selectChannel(obj: T): PushOutputChannel<T>

Selects the destination channel for an entity.