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

下面列出了怎么用io.netty.util.Recycler.Handle的API类实例代码及写法,或者点击链接到github查看源代码。

源代码1 项目: kop   文件: MessagePublishContext.java
private MessagePublishContext(Handle<MessagePublishContext> recyclerHandle) {
    this.recyclerHandle = recyclerHandle;
}
 
源代码2 项目: netty4.0.27Learn   文件: RecyclableArrayList.java
private RecyclableArrayList(Handle handle) {
    this(handle, DEFAULT_INITIAL_CAPACITY);
}
 
源代码3 项目: kop   文件: MessageFetchContext.java
private MessageFetchContext(Handle<MessageFetchContext> recyclerHandle) {
    this.recyclerHandle = recyclerHandle;
}
 
源代码4 项目: kop   文件: MessageFetchContext.java
protected MessageFetchContext newObject(Handle<MessageFetchContext> handle) {
    return new MessageFetchContext(handle);
}
 
源代码5 项目: netty-4.1.22   文件: FlowControlHandler.java
@Override
protected RecyclableArrayDeque newObject(Handle<RecyclableArrayDeque> handle) {
    return new RecyclableArrayDeque(DEFAULT_NUM_ELEMENTS, handle);
}
 
源代码6 项目: netty-4.1.22   文件: FlowControlHandler.java
private RecyclableArrayDeque(int numElements, Handle<RecyclableArrayDeque> handle) {
    super(numElements);
    this.handle = handle;
}
 
源代码7 项目: netty-4.1.22   文件: ChannelOutboundBuffer.java
@Override
protected Entry newObject(Handle<Entry> handle) {
    return new Entry(handle);
}
 
源代码8 项目: netty-4.1.22   文件: ChannelOutboundBuffer.java
private Entry(Handle<Entry> handle) {
    this.handle = handle;
}
 
源代码9 项目: netty-4.1.22   文件: PooledSlicedByteBuf.java
@Override
protected PooledSlicedByteBuf newObject(Handle<PooledSlicedByteBuf> handle) {
    return new PooledSlicedByteBuf(handle);
}
 
源代码10 项目: netty-4.1.22   文件: PooledSlicedByteBuf.java
private PooledSlicedByteBuf(Handle<PooledSlicedByteBuf> handle) {
    super(handle);
}
 
源代码11 项目: netty-4.1.22   文件: PooledUnsafeHeapByteBuf.java
@Override
protected PooledUnsafeHeapByteBuf newObject(Handle<PooledUnsafeHeapByteBuf> handle) {
    return new PooledUnsafeHeapByteBuf(handle, 0);
}
 
源代码12 项目: netty-4.1.22   文件: PooledUnsafeHeapByteBuf.java
private PooledUnsafeHeapByteBuf(Handle<PooledUnsafeHeapByteBuf> recyclerHandle, int maxCapacity) {
    super(recyclerHandle, maxCapacity);
}
 
@SuppressWarnings("unchecked")
AbstractPooledDerivedByteBuf(Handle<? extends AbstractPooledDerivedByteBuf> recyclerHandle) {
    super(0);
    this.recyclerHandle = (Handle<AbstractPooledDerivedByteBuf>) recyclerHandle;
}
 
源代码14 项目: netty-4.1.22   文件: PoolThreadCache.java
Entry(Handle<Entry<?>> recyclerHandle) {
    this.recyclerHandle = recyclerHandle;
}
 
源代码15 项目: netty-4.1.22   文件: PoolThreadCache.java
@SuppressWarnings("unchecked")
@Override
protected Entry newObject(Handle<Entry> handle) {
    return new Entry(handle);
}
 
源代码16 项目: netty-4.1.22   文件: ByteBufUtil.java
@Override
protected ThreadLocalUnsafeDirectByteBuf newObject(Handle<ThreadLocalUnsafeDirectByteBuf> handle) {
    return new ThreadLocalUnsafeDirectByteBuf(handle);
}
 
源代码17 项目: netty-4.1.22   文件: ByteBufUtil.java
private ThreadLocalUnsafeDirectByteBuf(Handle<ThreadLocalUnsafeDirectByteBuf> handle) {
    super(UnpooledByteBufAllocator.DEFAULT, 256, Integer.MAX_VALUE);
    this.handle = handle;
}
 
源代码18 项目: netty-4.1.22   文件: ByteBufUtil.java
@Override
protected ThreadLocalDirectByteBuf newObject(Handle<ThreadLocalDirectByteBuf> handle) {
    return new ThreadLocalDirectByteBuf(handle);
}
 
源代码19 项目: ProtocolSupportBungee   文件: ConnectionImpl.java
@Override
protected LPacketEvent newObject(Handle<LPacketEvent> handle) {
	return new LPacketEvent(handle);
}
 
源代码20 项目: rsocket-java   文件: ByteBufPayload.java
private ByteBufPayload(final Handle<ByteBufPayload> handle) {
  this.handle = handle;
}
 
源代码21 项目: netty-4.1.22   文件: PooledDuplicatedByteBuf.java
private PooledDuplicatedByteBuf(Handle<PooledDuplicatedByteBuf> handle) {
    super(handle);
}
 
源代码22 项目: netty-4.1.22   文件: PooledByteBuf.java
@SuppressWarnings("unchecked")
protected PooledByteBuf(Recycler.Handle<? extends PooledByteBuf<T>> recyclerHandle, int maxCapacity) {
    super(maxCapacity);
    this.recyclerHandle = (Handle<PooledByteBuf<T>>) recyclerHandle;
}
 
源代码23 项目: netty-4.1.22   文件: RecyclableArrayList.java
@Override
protected RecyclableArrayList newObject(Handle<RecyclableArrayList> handle) {
    return new RecyclableArrayList(handle);
}
 
源代码24 项目: netty-4.1.22   文件: RecyclableArrayList.java
private RecyclableArrayList(Handle<RecyclableArrayList> handle) {
    this(handle, DEFAULT_INITIAL_CAPACITY);
}
 
源代码25 项目: netty-4.1.22   文件: RecyclableArrayList.java
private RecyclableArrayList(Handle<RecyclableArrayList> handle, int initialCapacity) {
    super(initialCapacity);
    this.handle = handle;
}
 
源代码26 项目: turbo-rpc   文件: RecycleResponse.java
protected RecycleResponse newObject(Recycler.Handle<RecycleResponse> handle) {
	return new RecycleResponse(handle);
}
 
源代码27 项目: turbo-rpc   文件: RecycleResponse.java
private RecycleResponse(Handle<RecycleResponse> handle) {
	this.handle = handle;
}
 
源代码28 项目: netty4.0.27Learn   文件: RecyclableArrayList.java
private RecyclableArrayList(Handle handle, int initialCapacity) {
    super(initialCapacity);
    this.handle = handle;
}
 
源代码29 项目: turbo-rpc   文件: RecycleRequest.java
private RecycleRequest(Handle<RecycleRequest> handle) {
	this.handle = handle;
}
 
源代码30 项目: NioImapClient   文件: ImapClient.java
@Override
protected PendingCommand newObject(Handle<PendingCommand> handle) {
  return new PendingCommand(handle);
}
 
 类所在包
 同包方法