rebuildActiveExecutors() — netty Function Reference

Source Code

common/src/main/java/io/netty/util/concurrent/AutoScalingEventExecutorChooserFactory.java lines 397–418

            private void rebuildActiveExecutors() {
                for (;;) {
                    AutoScalingState oldState = state.get();
                    List<EventExecutor> active = new ArrayList<>(oldState.activeChildrenCount);
                    for (EventExecutor executor : executors) {
                        if (!executor.isSuspended()) {
                            active.add(executor);
                        }
                    }
                    EventExecutor[] newActiveExecutors = active.toArray(new EventExecutor[0]);

                    // If the number of active executors in our scan differs from the count in the state,
                    // another thread likely changed it. We use the count from our fresh scan.
                    // The nextWakeUpIndex is preserved from the old state as this rebuild is not a scale-up action.
                    AutoScalingState newState = new AutoScalingState(
                            newActiveExecutors.length, oldState.nextWakeUpIndex, newActiveExecutors);

                    if (state.compareAndSet(oldState, newState)) {
                        break;
                    }
                }
            }