testSuspensionWhenExecutorIsNotStarted() — netty Function Reference

Source Code

common/src/test/java/io/netty/util/concurrent/SingleThreadEventExecutorTest.java lines 145–169

    @Test
    void testSuspensionWhenExecutorIsNotStarted() throws Exception {
        TestThreadFactory threadFactory = new TestThreadFactory();
        final SingleThreadEventExecutor executor = new SuspendingSingleThreadEventExecutor(threadFactory);
        // suspend when executor is not started yet
        assertTrue(executor.trySuspend());
        assertTrue(executor.isSuspended());

        // recover from suspension by executing a task
        LatchTask task1 = new LatchTask();
        executor.execute(task1);
        Thread currentThread = threadFactory.threads.take();
        assertFalse(executor.isSuspended());
        task1.await();

        executor.shutdownGracefully(0, 0, TimeUnit.MILLISECONDS).syncUninterruptibly();
        currentThread.join();
        assertFalse(executor.isSuspended());
        assertTrue(executor.isShutdown());

        // Guarantee that all threads were able to die...
        while ((currentThread = threadFactory.threads.poll()) != null) {
            currentThread.join();
        }
    }