AllocConfig Class — netty Architecture

Source Code

microbench/src/main/java/io/netty/buffer/AllocationPatternSimulator.java lines 577–604

    private final class AllocConfig {
        private final AbstractByteBufAllocator allocator;
        private final int avgLiveBufs;
        private final SplittableRandom rng;
        private final String name;

        AllocConfig(boolean isAdaptive, int avgLiveBufs) {
            allocator = isAdaptive ? new AdaptiveByteBufAllocator() : new PooledByteBufAllocator();
            name = String.format(isAdaptive ? "Adaptive (%s)" : "Pooled (%s)", avgLiveBufs);
            this.avgLiveBufs = avgLiveBufs;
            rng = new SplittableRandom(0xBEEFBEEFL);
        }

        Thread start(CountDownLatch startLatch, AtomicBoolean stopCondition) {
            return new Workload(startLatch, allocator, rng.split(), stopCondition, avgLiveBufs).start(name);
        }

        long usedMemory() {
            if (allocator instanceof AdaptiveByteBufAllocator) {
                return ((AdaptiveByteBufAllocator) allocator).usedHeapMemory();
            }
            return ((PooledByteBufAllocator) allocator).usedHeapMemory();
        }

        String name() {
            return name;
        }
    }