testScalingWithIoRegistrationLifecycle() — netty Function Reference

Source Code

transport/src/test/java/io/netty/channel/MultiThreadIoEventLoopGroupTest.java lines 144–175

    @Test
    @Timeout(30)
    public void testScalingWithIoRegistrationLifecycle() throws InterruptedException {
        TestMultiThreadIoEventLoopGroup group = new TestMultiThreadIoEventLoopGroup(0, 2, 200, TimeUnit.MILLISECONDS);
        try {
            startAllExecutors(group);
            assertEquals(2, countActiveExecutors(group));

            waitForSuspension(group, 1, 2000);
            assertEquals(1, countActiveExecutors(group), "One executor should have been suspended");

            TestableIoEventLoop activeExecutor = (TestableIoEventLoop) findActiveExecutor(group);
            assertNotNull(activeExecutor, "One executor should remain active");

            IoRegistration registration = activeExecutor.register(new TestIoHandle()).syncUninterruptibly().getNow();
            activeExecutor.setSimulateWorkload(true);

            Thread.sleep(450);

            // The executor will not be suspended because its workload generates utilization.
            assertFalse(activeExecutor.isSuspended(), "Executor with active handle should not be suspended");

            activeExecutor.setSimulateWorkload(false);
            assertTrue(registration.cancel());

            waitForSuspension(group, 2, 2000);
            assertTrue(activeExecutor.isSuspended(),
                       "Executor should suspend after handle is cancelled and idle");
        } finally {
            group.shutdownGracefully().syncUninterruptibly();
        }
    }