Java 类io.netty.util.concurrent.EventExecutorGroup 实例源码

项目：NioImapClient 文件：ImapClient.java

public ImapClient(ImapClientConfiguration configuration,
                  Channel channel,
                  SslContext sslContext,
                  EventExecutorGroup promiseExecutor,
                  String clientName) {
  this.logger = LogUtils.loggerWithName(ImapClient.class, clientName);
  this.configuration = configuration;
  this.channel = channel;
  this.sslContext = sslContext;
  this.promiseExecutor = promiseExecutor;
  this.clientState = new ImapClientState(clientName, promiseExecutor);
  this.codec = new ImapCodec(clientState);
  this.pendingWriteQueue = new ConcurrentLinkedQueue<>();
  this.connectionShutdown = new AtomicBoolean(false);
  this.connectionClosed = new AtomicBoolean(false);
  this.capabilities = new AtomicReference<>(null);

  configureChannel();
}

项目：sailfish 文件：ReadWriteExchangeChannelGroup.java

public ReadWriteExchangeChannelGroup(MsgHandler<Protocol> msgHandler, Address address, int connectTimeout,
        int reconnectInterval, byte idleTimeout, byte maxIdleTimeOut, boolean lazy, short connections,
        short writeConnections, boolean reverseIndex, EventLoopGroup loopGroup, EventExecutorGroup executorGroup)
        throws SailfishException {
    super(UUID.randomUUID());
    this.msgHandler = msgHandler;
    this.tracer = new Tracer();

    NegotiateConfig readConfig = new NegotiateConfig(idleTimeout, maxIdleTimeOut, id(), ChannelType.read.code(),
            connections, writeConnections, (short) 0, reverseIndex);
    this.readGroup = new DefaultExchangeChannelGroup(tracer, msgHandler, address,
            (short) (connections - writeConnections), connectTimeout, reconnectInterval, idleTimeout,
            maxIdleTimeOut, lazy, reverseIndex, readConfig, this, loopGroup, executorGroup);

    NegotiateConfig writeConfig = new NegotiateConfig(idleTimeout, maxIdleTimeOut, id(), ChannelType.write.code(),
            connections, writeConnections, (short) 0, reverseIndex);
    this.writeGroup = new DefaultExchangeChannelGroup(tracer, msgHandler, address, writeConnections, connectTimeout,
            reconnectInterval, idleTimeout, maxIdleTimeOut, lazy, reverseIndex, writeConfig, this, loopGroup,
            executorGroup);
}

项目：sailfish 文件：AbstractConfigurableExchangeChannelGroup.java

private ChannelInitializer<SocketChannel> newChannelInitializer(final NegotiateConfig config,
        final ExchangeChannelGroup channelGroup, final EventExecutorGroup executorGroup) {
    return new ChannelInitializer<SocketChannel>() {
        @Override
        protected void initChannel(SocketChannel ch) throws Exception {
            ChannelPipeline pipeline = ch.pipeline();
            ch.attr(ChannelAttrKeys.maxIdleTimeout).set(config.maxIdleTimeout());
            ch.attr(ChannelAttrKeys.channelGroup).set(channelGroup);
            ch.attr(ChannelAttrKeys.clientSide).set(true);
            ch.attr(OneTime.awaitNegotiate).set(new CountDownLatch(1));
            ch.attr(OneTime.channelConfig).set(config);
            // TODO should increase ioRatio when every ChannelHandler bind to executorGroup?
            pipeline.addLast(executorGroup, 
                    RemotingEncoder.INSTANCE, 
                    new RemotingDecoder(), 
                    new IdleStateHandler(config.idleTimeout(), 0, 0), 
                    HeartbeatChannelHandler.INSTANCE,
                    NegotiateChannelHandler.INSTANCE,
                    ConcreteRequestHandler.INSTANCE);
        }
    };
}

项目：riposte 文件：Server.java

public void shutdown() throws InterruptedException {
    try {
        logger.info("Shutting down Riposte...");
        List<ChannelFuture> channelCloseFutures = new ArrayList<>();
        for (Channel ch : channels) {
            // execute shutdown hooks
            if (serverConfig.serverShutdownHooks() != null) {
                for (ServerShutdownHook hook : serverConfig.serverShutdownHooks()) {
                    hook.executeServerShutdownHook(serverConfig, ch);
                }
            }

            channelCloseFutures.add(ch.close());
        }
        for (ChannelFuture chf : channelCloseFutures) {
            chf.sync();
        }
    }
    finally {
        eventLoopGroups.forEach(EventExecutorGroup::shutdownGracefully);
        logger.info("...Riposte shutdown complete");
    }
}

项目：Nomad 文件：NomadServer.java

public NomadServer(NomadLobby nLobby, EventLoopGroup bossGroup, EventLoopGroup workerGroup,
        EventExecutorGroup executorGroup) {
    sb = new ServerBootstrap();
    sb.group(bossGroup, workerGroup);
    sb.channel(NioServerSocketChannel.class);

    final int BUF_PER_CLIENT = Packet.MAX_PACKET_LENGTH * 4;
    final int MAX_CLIENTS = 2000;

    sb.option(ChannelOption.SO_BACKLOG, MAX_CLIENTS);
    sb.option(ChannelOption.SO_REUSEADDR, true);
    sb.childOption(ChannelOption.ALLOCATOR, PooledByteBufAllocator.DEFAULT);
    sb.childOption(ChannelOption.RCVBUF_ALLOCATOR, new FixedRecvByteBufAllocator(BUF_PER_CLIENT));
    sb.childOption(ChannelOption.SO_SNDBUF, 65535);
    sb.childOption(ChannelOption.SO_RCVBUF, 65535);

    sb.childHandler(new ServerHandler(nLobby, executorGroup));
    String ip = Nomad.BIND_ON_ALL ? "0.0.0.0" : nLobby.getLobby().getIp();
    sb.localAddress(ip, nLobby.getLobby().getPort());
}

项目：jannel 文件：JannelClientTest.java

@Test(expected = PrematureChannelClosureException.class)
public void testIdentifyCloseChannelOnFailure() throws Exception {
    Channel channel = mock(Channel.class, Answers.RETURNS_SMART_NULLS.get());
    mockWriteHandler = mock(ChannelHandler.class);

    DefaultChannelPromise completedFuture = new DefaultChannelPromise(channel);
    completedFuture.setSuccess();

    DefaultChannelPromise failedFuture = new DefaultChannelPromise(channel);
    failedFuture.setFailure(new PrematureChannelClosureException("test"));

    ChannelPipeline channelPipeline = mock(ChannelPipeline.class);
    when(channelPipeline.addLast(anyString(), any(ChannelHandler.class))).thenReturn(channelPipeline);
    when(channelPipeline.addLast(any(EventExecutorGroup.class), anyString(), any(ChannelHandler.class))).thenReturn(channelPipeline);
    when(channel.pipeline()).thenReturn(channelPipeline);
    when(channel.isActive()).thenReturn(true);
    when(channel.writeAndFlush(any())).thenReturn(failedFuture);
    when(channel.close()).thenReturn(completedFuture);

    when(bootstrap.connect(anyString(), anyInt())).thenReturn(completedFuture);

    ClientSessionConfiguration configuration = new ClientSessionConfiguration();

    jannelClient.identify(configuration, null);
}

项目：hackathon-2015 文件：Server.java

public static void main(String[] args) throws Exception {
    init();
    EventExecutorGroup eventExecutorGroup = new NioEventLoopGroup(16);
    /**
     * POST     /login
     * GET      /foods
     * POST     /carts
     * PATCH    /carts/cart_id
     * POST     /orders
     * GET      /orders
     * GET      /admin/orders
     */
    HttpServerUrlHandler httpServerUrlHandler = new HttpServerUrlHandler(new DefaultHandler(HttpResponseStatus.BAD_GATEWAY))
            .register(HttpMethod.POST, "/login", new LoginHandler())
            .register(HttpMethod.GET, "/foods", new GetStockHandler())
            .register(HttpMethod.POST, "/carts", new AddCartHandler())
            .register(HttpMethod.PATCH, "/carts", new AddFoodHandler())
            .register(HttpMethod.POST, "/orders", new MakeOrderHandler())
            .register(HttpMethod.GET, "/orders", new GetOrderHandler())
            .register(HttpMethod.GET, "/admin/orders", new AdminGetOrderHandler());


    new HttpServer(128, ch -> ch.pipeline().addLast(httpServerUrlHandler)).start(Integer.parseInt(Config.APP_PORT));


}

项目：netty4.0.27Learn 文件：DefaultChannelPipeline.java

@Override
public ChannelPipeline addFirst(EventExecutorGroup executor, ChannelHandler... handlers) {
    if (handlers == null) {
        throw new NullPointerException("handlers");
    }
    if (handlers.length == 0 || handlers[0] == null) {
        return this;
    }

    int size;
    for (size = 1; size < handlers.length; size ++) {
        if (handlers[size] == null) {
            break;
        }
    }

    for (int i = size - 1; i >= 0; i --) {
        ChannelHandler h = handlers[i];
        addFirst(executor, generateName(h), h);
    }

    return this;
}

项目：netty4study 文件：DefaultChannelPipeline.java

@Override
public ChannelPipeline addFirst(EventExecutorGroup executor, ChannelHandler... handlers) {
    if (handlers == null) {
        throw new NullPointerException("handlers");
    }
    if (handlers.length == 0 || handlers[0] == null) {
        return this;
    }

    int size;
    for (size = 1; size < handlers.length; size++) {
        if (handlers[size] == null) {
            break;
        }
    }

    for (int i = size - 1; i >= 0; i--) {
        ChannelHandler h = handlers[i];
        addFirst(executor, generateName(h), h);
    }

    return this;
}

项目：lettuce-core 文件：DefaultClientResourcesTest.java

@Test
public void testBuilder() throws Exception {

    DefaultClientResources sut = new DefaultClientResources.Builder().ioThreadPoolSize(4).computationThreadPoolSize(4)
            .commandLatencyCollectorOptions(DefaultCommandLatencyCollectorOptions.disabled()).build();

    EventExecutorGroup eventExecutors = sut.eventExecutorGroup();
    NioEventLoopGroup eventLoopGroup = sut.eventLoopGroupProvider().allocate(NioEventLoopGroup.class);

    assertThat(eventExecutors.iterator()).hasSize(4);
    assertThat(eventLoopGroup.executorCount()).isEqualTo(4);
    assertThat(sut.ioThreadPoolSize()).isEqualTo(4);
    assertThat(sut.commandLatencyCollector()).isNotNull();
    assertThat(sut.commandLatencyCollector().isEnabled()).isFalse();

    assertThat(sut.shutdown(0, 0, TimeUnit.MILLISECONDS).get()).isTrue();
}

项目：lettuce-core 文件：RedisClientTest.java

@Test
public void reuseClientConnections() throws Exception {

    // given
    DefaultClientResources clientResources = DefaultClientResources.create();
    Map<Class<? extends EventExecutorGroup>, EventExecutorGroup> eventLoopGroups = getExecutors(clientResources);

    RedisClient redisClient1 = newClient(clientResources);
    RedisClient redisClient2 = newClient(clientResources);
    connectAndClose(redisClient1);
    connectAndClose(redisClient2);

    // when
    EventExecutorGroup executor = eventLoopGroups.values().iterator().next();
    redisClient1.shutdown(0, 0, TimeUnit.MILLISECONDS);

    // then
    connectAndClose(redisClient2);

    clientResources.shutdown(0, 0, TimeUnit.MILLISECONDS).get();

    assertThat(eventLoopGroups).isEmpty();
    assertThat(executor.isShuttingDown()).isTrue();
    assertThat(clientResources.eventExecutorGroup().isShuttingDown()).isTrue();
}

项目：lettuce-core 文件：RedisClientTest.java

@Test
public void managedClientResources() throws Exception {

    // given
    RedisClient redisClient1 = RedisClient.create(RedisURI.create(TestSettings.host(), TestSettings.port()));
    ClientResources clientResources = redisClient1.getResources();
    Map<Class<? extends EventExecutorGroup>, EventExecutorGroup> eventLoopGroups = getExecutors(clientResources);
    connectAndClose(redisClient1);

    // when
    EventExecutorGroup executor = eventLoopGroups.values().iterator().next();

    redisClient1.shutdown(0, 0, TimeUnit.MILLISECONDS);

    // then
    assertThat(eventLoopGroups).isEmpty();
    assertThat(executor.isShuttingDown()).isTrue();
    assertThat(clientResources.eventExecutorGroup().isShuttingDown()).isTrue();
}

项目：netty-netty-5.0.0.Alpha1 文件：DefaultChannelPipeline.java

private ChannelHandlerInvoker findInvoker(EventExecutorGroup group) {
    if (group == null) {
        return null;
    }

    // Pin one of the child executors once and remember it so that the same child executor
    // is used to fire events for the same channel.
    ChannelHandlerInvoker invoker = childInvokers.get(group);
    if (invoker == null) {
        EventExecutor executor = group.next();
        if (executor instanceof EventLoop) {
            invoker = ((EventLoop) executor).asInvoker();
        } else {
            invoker = new DefaultChannelHandlerInvoker(executor);
        }
        childInvokers.put(group, invoker);
    }

    return invoker;
}

项目：jooby 文件：NettyPipeline.java

public NettyPipeline(final EventExecutorGroup executor, final HttpHandler handler,
    final Config conf, final SslContext sslCtx) {
  this.executor = executor;
  this.handler = handler;
  this.config = conf;

  maxInitialLineLength = conf.getBytes("netty.http.MaxInitialLineLength").intValue();
  maxHeaderSize = conf.getBytes("netty.http.MaxHeaderSize").intValue();
  maxChunkSize = conf.getBytes("netty.http.MaxChunkSize").intValue();
  maxContentLength = conf.getBytes("netty.http.MaxContentLength").intValue();
  idleTimeOut = conf.getDuration("netty.http.IdleTimeout", TimeUnit.MILLISECONDS);
  supportH2 = conf.getBoolean("server.http2.enabled");
  this.tmpdir = config.getString("application.tmpdir");
  this.bufferSize = config.getBytes("server.http.ResponseBufferSize").intValue();
  this.wsMaxMessageSize = Math
      .max(
          config.getBytes("server.ws.MaxTextMessageSize").intValue(),
          config.getBytes("server.ws.MaxBinaryMessageSize").intValue());
  this.sslCtx = sslCtx;
}