setupAllocatorAndPollute() — netty Function Reference

Source Code

microbench/src/main/java/io/netty/microbench/buffer/ByteBufAllocatorAllocPatternBenchmark.java lines 175–211

    @Setup
    public void setupAllocatorAndPollute(BenchmarkParams params) throws InterruptedException {
        allocator = allocatorType.create();
        if (pollutionIterations == 0) {
            return;
        }

        final boolean directAllocation = params.getBenchmark().contains("Direct");

        int perThreadIterations = pollutionIterations / 2;

        Runnable pollutionTask = () -> {
            AllocationPatternState state = new AllocationPatternState();
            state.setup(this);
            try {
                if (directAllocation) {
                    for (int i = 0; i < perThreadIterations; i++) {
                        state.performDirectAllocation();
                    }
                } else {
                    for (int i = 0; i < perThreadIterations; i++) {
                        state.performHeapAllocation();
                    }
                }
            } finally {
                state.tearDown();
            }
        };

        Thread normalThread = new Thread(pollutionTask);
        Thread fastThread = new FastThreadLocalThread(pollutionTask);

        normalThread.start();
        fastThread.start();
        normalThread.join();
        fastThread.join();
    }