pooledBufferAllocation() — netty Function Reference

Source Code

transport-blockhound-tests/src/test/java/io/netty/util/internal/NettyBlockHoundIntegrationTest.java lines 367–395

    @Test
    @Timeout(value = 5000, unit = TimeUnit.MILLISECONDS)
    public void pooledBufferAllocation() throws Exception {
        AtomicLong iterationCounter = new AtomicLong();
        PooledByteBufAllocator allocator = PooledByteBufAllocator.DEFAULT;
        FutureTask<Void> task = new FutureTask<>(() -> {
            List<ByteBuf> buffers = new ArrayList<>();
            long count;
            do {
                count = iterationCounter.get();
            } while (count == 0);
            for (int i = 0; i < 13; i++) {
                int size = 8 << i;
                buffers.add(allocator.ioBuffer(size, size));
            }
            for (ByteBuf buffer : buffers) {
                buffer.release();
            }
            return null;
        });
        FastThreadLocalThread thread = new FastThreadLocalThread(task);
        thread.start();
        do {
            allocator.dumpStats(); // This will take internal pool locks and we'll race with the thread.
            iterationCounter.set(1);
        } while (thread.isAlive());
        thread.join();
        task.get();
    }