testNotPinExecutor() — netty Function Reference

Architecture documentation for the testNotPinExecutor() function in DefaultChannelPipelineTest.java from the netty codebase.

Function java Buffer Search calls 1

Entity Profile

Buffer→ Search→ testNotPinExecutor() — netty Function Reference

Dependency Diagram

graph TD
  da4d523e_a93a_cfdf_e379_b8476f9a31c3["testNotPinExecutor()"]
  666d912b_4166_a807_ed10_ba12f328a7b2["DefaultChannelPipelineTest"]
  da4d523e_a93a_cfdf_e379_b8476f9a31c3 -->|defined in| 666d912b_4166_a807_ed10_ba12f328a7b2
  19bd3906_4c8c_ae23_6c05_b7a84d367379["shutdownGracefully()"]
  da4d523e_a93a_cfdf_e379_b8476f9a31c3 -->|calls| 19bd3906_4c8c_ae23_6c05_b7a84d367379
  style da4d523e_a93a_cfdf_e379_b8476f9a31c3 fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

transport/src/test/java/io/netty/channel/DefaultChannelPipelineTest.java lines 1596–1611

    @Test
    public void testNotPinExecutor() {
        EventExecutorGroup group = new MultiThreadIoEventLoopGroup(2, LocalIoHandler.newFactory());
        ChannelPipeline pipeline = new LocalChannel().pipeline();
        pipeline.channel().config().setOption(ChannelOption.SINGLE_EVENTEXECUTOR_PER_GROUP, false);

        pipeline.addLast(group, "h1", new ChannelInboundHandlerAdapter());
        pipeline.addLast(group, "h2", new ChannelInboundHandlerAdapter());

        EventExecutor executor1 = pipeline.context("h1").executor();
        EventExecutor executor2 = pipeline.context("h2").executor();
        assertNotNull(executor1);
        assertNotNull(executor2);
        assertNotSame(executor1, executor2);
        group.shutdownGracefully(0, 0, TimeUnit.SECONDS);
    }