5-1.Netty源码:Pipeline初始化

1
2
3
4
5
6
7
8
9
10
11
12
//AbstractChannel.java->DefaultChannelPipeline.java
protected DefaultChannelPipeline(Channel channel) {
  this.channel = ObjectUtil.checkNotNull(channel, "channel");
  succeededFuture = new SucceededChannelFuture(channel, null);
  voidPromise = new VoidChannelPromise(channel, true);

  tail = new TailContext(this);
  head = new HeadContext(this);

  head.next = tail;
  tail.prev = head;
}

1
2
3
4
5
6
//AbstractChannelHandlerContext.java
TailContext(DefaultChannelPipeline pipeline) {
    super(pipeline, null, TAIL_NAME, true, false);
    setAddComplete();
}

1
2
3
4
5
6
//AbstractChannelHandlerContext.java
HeadContext(DefaultChannelPipeline pipeline) {
    super(pipeline, null, HEAD_NAME, false, true);
    unsafe = pipeline.channel().unsafe();
    setAddComplete();
}

1
2
3
4
5
6
7
8
9
10
//AbstractChannelHandlerContext.java
AbstractChannelHandlerContext(DefaultChannelPipeline pipeline, EventExecutor executor, String name,
                              boolean inbound, boolean outbound) {
  this.name = ObjectUtil.checkNotNull(name, "name");
  this.pipeline = pipeline;
  this.executor = executor;
  this.inbound = inbound;
  this.outbound = outbound;
  ordered = executor == null || executor instanceof OrderedEventExecutor;
}