Package io.netty.util.concurrent

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 java.lang.Object
implements EventExecutorChooserFactory.ObservableEventExecutorChooser

Nested Class Summary

Nested Classes

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

Field Summary

Fields

Modifier and Type	Field	Description
private EventExecutorChooserFactory.EventExecutorChooser	allExecutorsChooser
private EventExecutor[]	executors
private java.util.concurrent.atomic.AtomicReference<AutoScalingEventExecutorChooserFactory.AutoScalingState>	state
private java.util.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.
java.util.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 java.lang.Object

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

Field Detail

executors

private final EventExecutor[] executors

allExecutorsChooser

private final EventExecutorChooserFactory.EventExecutorChooser allExecutorsChooser

state

private final java.util.concurrent.atomic.AtomicReference<AutoScalingEventExecutorChooserFactory.AutoScalingState> state

utilizationMetrics

private final java.util.List<AutoScalingEventExecutorChooserFactory.AutoScalingUtilizationMetric> utilizationMetrics

Constructor Detail

AutoScalingEventExecutorChooser

AutoScalingEventExecutorChooser(EventExecutor[] executors)

Method Detail

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 java.util.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.