producer() — netty Function Reference

Architecture documentation for the producer() function in RecyclerBenchmark.java from the netty codebase.

Function java Buffer Telemetry

Entity Profile

Buffer→ Telemetry→ producer() — netty Function Reference

Dependency Diagram

graph TD
  c2a84a22_a2ff_b27c_f8fa_aa2b05998a09["producer()"]
  f3ce3bf7_0aec_591c_d35b_cfe2adfbfa83["RecyclerBenchmark"]
  c2a84a22_a2ff_b27c_f8fa_aa2b05998a09 -->|defined in| f3ce3bf7_0aec_591c_d35b_cfe2adfbfa83
  style c2a84a22_a2ff_b27c_f8fa_aa2b05998a09 fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

microbench/src/main/java/io/netty/microbench/util/RecyclerBenchmark.java lines 123–136

    @Benchmark
    @Group("producerConsumer")
    @BenchmarkMode(Mode.Throughput)
    @OutputTimeUnit(TimeUnit.MICROSECONDS)
    public void producer(ProducerConsumerState state, Control control, ProducerStats stats) throws Exception {
        Queue<DummyObject> queue = state.queue;
        DummyObject object = state.recycler.get();
        while (!control.stopMeasurement) {
            if (queue.offer(object)) {
                break;
            }
            stats.fullQ++;
        }
    }