ports/com.group7.policies.fork/MostFullJoinPolicy

MostFullJoinPolicy

class MostFullJoinPolicy<T>(tags: Iterable<InputTag<Container<*>>> = generateSequence { newDynamicInputTag { it.walkUpstream().filterIsInstance<Container<*>>().first() } } .asIterable()) : JoinPolicy<T>

Join policy that pulls from the source with the highest occupancy. Helps balance load by pulling from the busiest source.

Parameters

the type of entities being merged

Constructors

MostFullJoinPolicy

constructor(tags: Iterable<InputTag<Container<*>>> = generateSequence { newDynamicInputTag { it.walkUpstream().filterIsInstance<Container<*>>().first() } } .asIterable())

Functions

initialize

context(_: Simulator)
open override fun initialize(sources: List<PullInputChannel<T>>, destination: PullOutputChannel<T>)

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

noneReady

open override fun noneReady(): Boolean

Checks if no source channels are ready.

onChannelNotReady

open override fun onChannelNotReady(channel: PullInputChannel<T>)

Called when a source channel is no longer ready (has no data available).

onChannelReady

open override fun onChannelReady(channel: PullInputChannel<T>)

Called when a source channel becomes ready (has data available).

selectChannel

open override fun selectChannel(): PullInputChannel<T>

Selects the source channel to pull from.