import io.netty.util.Recycler.Handle; //导入依赖的package包/类
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];
}
 

import io.netty.util.Recycler.Handle; //导入依赖的package包/类
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];
}
 

import io.netty.util.Recycler.Handle; //导入依赖的package包/类
@Override
protected PendingCommand newObject(Handle<PendingCommand> handle) {
  return new PendingCommand(handle);
}
 

import io.netty.util.Recycler.Handle; //导入依赖的package包/类
public PendingCommand(Handle<PendingCommand> handle) {
  this.handle = handle;
}
 

import io.netty.util.Recycler.Handle; //导入依赖的package包/类
@Override
protected CallbackTask newObject(Recycler.Handle<CallbackTask> handle) {
	return new CallbackTask(handle);
}
 

import io.netty.util.Recycler.Handle; //导入依赖的package包/类
public CallbackTask(Handle<CallbackTask> handle) {
	this.handle = handle;
}
 

import io.netty.util.Recycler.Handle; //导入依赖的package包/类
public CallbackCheckTask(Handle<CallbackCheckTask> handle) {
	this.handle = handle;
}
 

import io.netty.util.Recycler.Handle; //导入依赖的package包/类
private ProducerSendCallback(Handle<ProducerSendCallback> recyclerHandle) {
    this.recyclerHandle = recyclerHandle;
}
 

import io.netty.util.Recycler.Handle; //导入依赖的package包/类
@Override
protected ProducerSendCallback newObject(Handle<ProducerSendCallback> handle) {
    return new ProducerSendCallback(handle);
}
 

import io.netty.util.Recycler.Handle; //导入依赖的package包/类
private MessagePublishContext(Handle<MessagePublishContext> recyclerHandle) {
    this.recyclerHandle = recyclerHandle;
}
 

import io.netty.util.Recycler.Handle; //导入依赖的package包/类
protected MessagePublishContext newObject(Recycler.Handle<MessagePublishContext> handle) {
    return new MessagePublishContext(handle);
}
 

import io.netty.util.Recycler.Handle; //导入依赖的package包/类
private ReplicationMetrics(Handle<ReplicationMetrics> recyclerHandle) {
    this.recyclerHandle = recyclerHandle;
}
 

import io.netty.util.Recycler.Handle; //导入依赖的package包/类
@Override
protected ReplicationMetrics newObject(Recycler.Handle<ReplicationMetrics> handle) {
    return new ReplicationMetrics(handle);
}
 

import io.netty.util.Recycler.Handle; //导入依赖的package包/类
private WriteInEventLoopCallback(Handle<WriteInEventLoopCallback> recyclerHandle) {
    this.recyclerHandle = recyclerHandle;
}
 

import io.netty.util.Recycler.Handle; //导入依赖的package包/类
@Override
protected WriteInEventLoopCallback newObject(Handle<WriteInEventLoopCallback> handle) {
    return new WriteInEventLoopCallback(handle);
}
 

import io.netty.util.Recycler.Handle; //导入依赖的package包/类
private OpSendMsg(Handle<OpSendMsg> recyclerHandle) {
    this.recyclerHandle = recyclerHandle;
}
 

import io.netty.util.Recycler.Handle; //导入依赖的package包/类
private MessageImpl(Handle<MessageImpl> recyclerHandle) {
    this.recyclerHandle = recyclerHandle;
}
 

import io.netty.util.Recycler.Handle; //导入依赖的package包/类
@Override
protected MessageImpl newObject(Handle<MessageImpl> handle) {
    return new MessageImpl(handle);
}
 

import io.netty.util.Recycler.Handle; //导入依赖的package包/类
@Override
protected DoubleByteBuf newObject(Recycler.Handle<DoubleByteBuf> handle) {
    return new DoubleByteBuf(handle);
}
 

import io.netty.util.Recycler.Handle; //导入依赖的package包/类
private DoubleByteBuf(Handle<DoubleByteBuf> recyclerHandle) {
    super(Integer.MAX_VALUE);
    this.recyclerHandle = recyclerHandle;
}