Java 类io.netty.util.Recycler.Handle 实例源码

private ChannelOutboundBuffer(Handle handle) {
    this.handle = handle;


    buffer = new Entry[INITIAL_CAPACITY];
    for (int i = 0; i < buffer.length; i++) {
        buffer[i] = new Entry();
    }

    nioBuffers = new ByteBuffer[INITIAL_CAPACITY];
}

private ChannelOutboundBuffer(Handle<ChannelOutboundBuffer> handle) {
    this.handle = handle;

    buffer = new Entry[INITIAL_CAPACITY];
    for (int i = 0; i < buffer.length; i++) {
        buffer[i] = new Entry();
    }

    nioBuffers = new ByteBuffer[INITIAL_CAPACITY];
}

@Override
protected PendingCommand newObject(Handle<PendingCommand> handle) {
  return new PendingCommand(handle);
}

public PendingCommand(Handle<PendingCommand> handle) {
  this.handle = handle;
}

@Override
protected CallbackTask newObject(Recycler.Handle<CallbackTask> handle) {
    return new CallbackTask(handle);
}

public CallbackTask(Handle<CallbackTask> handle) {
    this.handle = handle;
}

@Override
protected CallbackCheckTask newObject(Recycler.Handle<CallbackCheckTask> handle) {
    return new CallbackCheckTask(handle);
}

public CallbackCheckTask(Handle<CallbackCheckTask> handle) {
    this.handle = handle;
}

private ProducerSendCallback(Handle<ProducerSendCallback> recyclerHandle) {
    this.recyclerHandle = recyclerHandle;
}

@Override
protected ProducerSendCallback newObject(Handle<ProducerSendCallback> handle) {
    return new ProducerSendCallback(handle);
}

private MessagePublishContext(Handle<MessagePublishContext> recyclerHandle) {
    this.recyclerHandle = recyclerHandle;
}

protected MessagePublishContext newObject(Recycler.Handle<MessagePublishContext> handle) {
    return new MessagePublishContext(handle);
}

private ProducerSendCallback(Handle<ProducerSendCallback> recyclerHandle) {
    this.recyclerHandle = recyclerHandle;
}

@Override
protected ProducerSendCallback newObject(Handle<ProducerSendCallback> handle) {
    return new ProducerSendCallback(handle);
}

private ReplicationMetrics(Handle<ReplicationMetrics> recyclerHandle) {
    this.recyclerHandle = recyclerHandle;
}

@Override
protected ReplicationMetrics newObject(Recycler.Handle<ReplicationMetrics> handle) {
    return new ReplicationMetrics(handle);
}

private WriteInEventLoopCallback(Handle<WriteInEventLoopCallback> recyclerHandle) {
    this.recyclerHandle = recyclerHandle;
}

@Override
protected WriteInEventLoopCallback newObject(Handle<WriteInEventLoopCallback> handle) {
    return new WriteInEventLoopCallback(handle);
}

private OpSendMsg(Handle<OpSendMsg> recyclerHandle) {
    this.recyclerHandle = recyclerHandle;
}

@Override
protected OpSendMsg newObject(Handle<OpSendMsg> handle) {
    return new OpSendMsg(handle);
}

private MessageImpl(Handle<MessageImpl> recyclerHandle) {
    this.recyclerHandle = recyclerHandle;
}

@Override
protected MessageImpl newObject(Handle<MessageImpl> handle) {
    return new MessageImpl(handle);
}

@Override
protected DoubleByteBuf newObject(Recycler.Handle<DoubleByteBuf> handle) {
    return new DoubleByteBuf(handle);
}

private DoubleByteBuf(Handle<DoubleByteBuf> recyclerHandle) {
    super(Integer.MAX_VALUE);
    this.recyclerHandle = recyclerHandle;
}

private ByteBufCodedOutputStream(Handle<ByteBufCodedOutputStream> handle) {
    this.recyclerHandle = handle;
}

protected ByteBufCodedOutputStream newObject(Recycler.Handle<ByteBufCodedOutputStream> handle) {
    return new ByteBufCodedOutputStream(handle);
}

private ByteBufCodedInputStream(Handle<ByteBufCodedInputStream> handle) {
    this.recyclerHandle = handle;
}

protected ByteBufCodedInputStream newObject(Recycler.Handle<ByteBufCodedInputStream> handle) {
    return new ByteBufCodedInputStream(handle);
}

private OpReadEntry(Handle<OpReadEntry> recyclerHandle) {
    this.recyclerHandle = recyclerHandle;
}

protected OpReadEntry newObject(Recycler.Handle<OpReadEntry> recyclerHandle) {
    return new OpReadEntry(recyclerHandle);
}

private OpAddEntry(Handle<OpAddEntry> recyclerHandle) {
    this.recyclerHandle = recyclerHandle;
}

protected OpAddEntry newObject(Recycler.Handle<OpAddEntry> recyclerHandle) {
    return new OpAddEntry(recyclerHandle);
}

@Override
protected EntryImpl newObject(Handle<EntryImpl> handle) {
    return new EntryImpl(handle);
}

private EntryImpl(Recycler.Handle<EntryImpl> recyclerHandle) {
    this.recyclerHandle = recyclerHandle;
}

@Override
protected Entry newObject(Handle handle) {
    return new Entry(handle);
}

private Entry(Handle handle) {
    this.handle = handle;
}

@Override
protected ThreadLocalUnsafeDirectByteBuf newObject(Handle handle) {
    return new ThreadLocalUnsafeDirectByteBuf(handle);
}

private ThreadLocalUnsafeDirectByteBuf(Handle handle) {
    super(UnpooledByteBufAllocator.DEFAULT, 256, Integer.MAX_VALUE);
    this.handle = handle;
}

@Override
protected ThreadLocalDirectByteBuf newObject(Handle handle) {
    return new ThreadLocalDirectByteBuf(handle);
}

private ThreadLocalDirectByteBuf(Handle handle) {
    super(UnpooledByteBufAllocator.DEFAULT, 256, Integer.MAX_VALUE);
    this.handle = handle;
}