PendingWrite Class — netty Architecture

Source Code

transport/src/main/java/io/netty/channel/PendingWriteQueue.java lines 306–340

    static final class PendingWrite {
        private static final Recycler<PendingWrite> RECYCLER =
                new Recycler<PendingWrite>() {
                    @Override
                    protected PendingWrite newObject(Handle<PendingWrite> handle) {
                        return new PendingWrite(handle);
                    }
                };

        private final ObjectPool.Handle<PendingWrite> handle;
        private PendingWrite next;
        private long size;
        private ChannelPromise promise;
        private Object msg;

        private PendingWrite(ObjectPool.Handle<PendingWrite> handle) {
            this.handle = handle;
        }

        static PendingWrite newInstance(Object msg, int size, ChannelPromise promise) {
            PendingWrite write = RECYCLER.get();
            write.size = size;
            write.msg = msg;
            write.promise = promise;
            return write;
        }

        private void recycle() {
            size = 0;
            next = null;
            msg = null;
            promise = null;
            handle.recycle(this);
        }
    }