Class AutoScalingEventExecutorChooserFactory.AutoScalingEventExecutorChooser

java.lang.Object

io.netty.util.concurrent.AutoScalingEventExecutorChooserFactory.AutoScalingEventExecutorChooser

All Implemented Interfaces:

EventExecutorChooserFactory.EventExecutorChooser, EventExecutorChooserFactory.ObservableEventExecutorChooser

Enclosing class:

AutoScalingEventExecutorChooserFactory

private final class AutoScalingEventExecutorChooserFactory.AutoScalingEventExecutorChooser
extends Object
implements EventExecutorChooserFactory.ObservableEventExecutorChooser

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
private final class	AutoScalingEventExecutorChooserFactory.AutoScalingEventExecutorChooser.UtilizationMonitor

Field Summary

Fields

Modifier and Type	Field	Description
private final EventExecutorChooserFactory.EventExecutorChooser	allExecutorsChooser
private final EventExecutor[]	executors
private final AtomicReference<AutoScalingEventExecutorChooserFactory.AutoScalingState>	state
private final List<AutoScalingEventExecutorChooserFactory.AutoScalingUtilizationMetric>	utilizationMetrics

Constructor Summary

Constructors

Constructor	Description
AutoScalingEventExecutorChooser(EventExecutor[] executors)

Method Summary

Modifier and Type	Method	Description
int	activeExecutorCount()	Returns the current number of active EventExecutors.
List<AutoScalingEventExecutorChooserFactory.AutoScalingUtilizationMetric>	executorUtilizations()	Returns a list containing the last calculated utilization for each EventExecutor in the group.
EventExecutor	next()	This method is only responsible for picking from the active executors list.
private void	tryScaleUpBy(int amount)	Tries to increase the active thread count by waking up suspended executors.

Methods inherited from class Object

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

Field Details

executors

private final EventExecutor[] executors

allExecutorsChooser

private final EventExecutorChooserFactory.EventExecutorChooser allExecutorsChooser

state

private final AtomicReference<AutoScalingEventExecutorChooserFactory.AutoScalingState> state

utilizationMetrics

private final List<AutoScalingEventExecutorChooserFactory.AutoScalingUtilizationMetric> utilizationMetrics

Constructor Details

AutoScalingEventExecutorChooser

AutoScalingEventExecutorChooser(EventExecutor[] executors)

Method Details

next

public EventExecutor next()

This method is only responsible for picking from the active executors list. The monitor handles all scaling decisions.

Specified by:

next in interface EventExecutorChooserFactory.EventExecutorChooser

tryScaleUpBy

private void tryScaleUpBy(int amount)

Tries to increase the active thread count by waking up suspended executors. This method is thread-safe and updates the state atomically.

Parameters:

amount - The desired number of threads to add to the active count.

activeExecutorCount

public int activeExecutorCount()

Description copied from interface: EventExecutorChooserFactory.ObservableEventExecutorChooser

Returns the current number of active EventExecutors.

Specified by:

activeExecutorCount in interface EventExecutorChooserFactory.ObservableEventExecutorChooser

Returns:

the number of active executors.

executorUtilizations

public List<AutoScalingEventExecutorChooserFactory.AutoScalingUtilizationMetric> executorUtilizations()

Description copied from interface: EventExecutorChooserFactory.ObservableEventExecutorChooser

Returns a list containing the last calculated utilization for each EventExecutor in the group.

Specified by:

executorUtilizations in interface EventExecutorChooserFactory.ObservableEventExecutorChooser

Returns:

an umodifiable view of the executor utilizations.