复制// 解码线程池  Executor decoderExecutor = ExecutorHelper.createExecutor(2,发现 "decoder");  // 转换线程池  Executor ectExecutor = ExecutorHelper.createExecutor(8, "ect");  // 发送线程池  Executor senderExecutor = ExecutorHelper.createExecutor(2, "sender");  @Override  protected void channelRead0(ChannelHandlerContext ctx, HttpRequest req) throws Exception {       CompletableFuture     // 解码过程              .supplyAsync(() -> this.decode(ctx, req), this.decoderExecutor)     // 转换过程              .thenApplyAsync(e -> this.doExtractCleanTransform(ctx, req, e), this.ectExecutor)     // IO 过程              .thenApplyAsync(e -> this.send(ctx, req, e), this.senderExecutor);  }  1.2.3.4.5.6.7.8.9.10.11.12.13.14.15.16.17.