PriorityPolicy

Priority policy. Selects the channel with the highest priority according to the provided comparator.

ChannelT

the type of channel managed by the policy

comparator

the Comparator that defines channel priorities

Constructors

constructor(comparator: Comparator<Int>)

open override fun allUnavailable(): Boolean

Checks if all channels are unavailable.

context(_: Simulator)
open override fun initialize(channels: List<ChannelT>)

Initializes the policy with the list of channels it will manage.

open override fun onChannelAvailable(channel: ChannelT)

Called when a channel becomes available (open for fork, ready for join).

open override fun onChannelUnavailable(channel: ChannelT)

Called when a channel becomes unavailable (closed for fork, not ready for join).

open override fun selectChannel(): ChannelT

Selects a channel from the available channels.