unguardedProducer() — netty Function Reference

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

Function java Buffer Telemetry

Entity Profile

Buffer→ Telemetry→ unguardedProducer() — netty Function Reference

Dependency Diagram

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

Relationship Graph

Source Code

microbench/src/main/java/io/netty/microbench/util/RecyclerBenchmark.java lines 162–173

    @Benchmark
    @Group("unguardedProducerConsumer")
    public void unguardedProducer(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++;
        }
    }