RecyclerTest Class — netty Architecture

Source Code

common/src/test/java/io/netty/util/RecyclerTest.java lines 50–615

public class RecyclerTest {

    public enum OwnerType {
        NONE,
        PINNED,
        FAST_THREAD_LOCAL,
    }

    public static Stream<Arguments> ownerTypeAndUnguarded() {
        return Arrays.stream(OwnerType.values())
                     .flatMap(owner -> Stream.of(true, false)
                                             .map(unguarded -> Arguments.of(owner, unguarded)));
    }

    public static Stream<Arguments> notNoneOwnerAndUnguarded() {
        return ownerTypeAndUnguarded().filter(args -> args.get()[0] != OwnerType.NONE);
    }

    protected static Recycler<HandledObject> newRecycler(OwnerType ownerType, boolean unguarded,
                                                         int maxCapacityPerThread) {
        return newRecycler(ownerType, unguarded, maxCapacityPerThread, null);
    }

    protected static Recycler<HandledObject> newRecycler(OwnerType ownerType, boolean unguarded,
                                                         int maxCapacityPerThread,
                                                         Consumer<HandledObject> onNewObject) {
        switch (ownerType) {
        case NONE:
            return new Recycler<HandledObject>(maxCapacityPerThread, unguarded) {
                @Override
                protected HandledObject newObject(Handle<HandledObject> handle) {
                    HandledObject newObj = new HandledObject(handle);
                    if (onNewObject != null) {
                        onNewObject.accept(newObj);
                    }
                    return newObj;
                }
            };
        case PINNED:
            return new Recycler<HandledObject>(maxCapacityPerThread >> 1, maxCapacityPerThread, Thread.currentThread(),
                                               unguarded) {
                @Override
                protected HandledObject newObject(
                        Recycler.Handle<HandledObject> handle) {
                    HandledObject newObj = new HandledObject(handle);
                    if (onNewObject != null) {
                        onNewObject.accept(newObj);
                    }
                    return newObj;
                }
            };
        case FAST_THREAD_LOCAL:
            return new Recycler<HandledObject>(maxCapacityPerThread >> 1, maxCapacityPerThread, unguarded) {
                @Override
                protected HandledObject newObject(Handle<HandledObject> handle) {
                    HandledObject newObj = new HandledObject(handle);
                    if (onNewObject != null) {
                        onNewObject.accept(newObj);
                    }
                    return newObj;
                }
            };
        default:
            throw new Error();
        }
    }

    protected static Recycler<HandledObject> newRecycler(boolean unguarded, int maxCapacityPerThread) {
        return new Recycler<HandledObject>(maxCapacityPerThread >> 1, maxCapacityPerThread, unguarded) {
            @Override
            protected HandledObject newObject(
                    Recycler.Handle<HandledObject> handle) {
                return new HandledObject(handle);
            }
        };
    }

    protected static Recycler<HandledObject> newRecycler(int maxCapacityPerThread) {
        return newRecycler(OwnerType.FAST_THREAD_LOCAL, false, maxCapacityPerThread, 8, maxCapacityPerThread >> 1);
    }