ports/com.group7.policies.generic_fj

Package-level declarations

Types

class FirstAvailablePolicy<ChannelT> : PriorityPolicy<ChannelT>

First-available policy. Always selects the channel with the lowest index among available channels. Equivalent to a priority policy that prefers earlier channels.

GenericPolicy

abstract class GenericPolicy<ChannelT>

Generic base class for simple routing policies used in both fork and join nodes. Provides a unified interface for channel selection and availability tracking that can be adapted to either push (fork) or pull (join) semantics.

PriorityPolicy

open class PriorityPolicy<ChannelT>(comparator: Comparator<Int>) : GenericPolicy<ChannelT>

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

RandomPolicy

class RandomPolicy<ChannelT> : GenericPolicy<ChannelT>

Random policy. Randomly selects from the available channels with equal probability.

RoundRobinPolicy

class RoundRobinPolicy<ChannelT> : GenericPolicy<ChannelT>

Round-robin policy. Selects channels in a cyclic order, ensuring fair distribution across available channels. Each time a channel is selected, the pointer advances to the next channel.

Functions

forkPolicy

fun <T> forkPolicy(policy: GenericPolicy<PushOutputChannel<T>>): ForkPolicy<T>

Wraps a generic policy to create a ForkPolicy for use in fork nodes.

joinPolicy

fun <T> joinPolicy(policy: GenericPolicy<PullInputChannel<T>>): JoinPolicy<T>

Wraps a generic policy to create a JoinPolicy for use in join nodes.