@Benchmark
    @Group("busy")
    @GroupThreads(1)
    public void writeBusy(Control cnt) {
        ChannelProducer<Ping> lProducer = producer;
		while (!lProducer.claim()) {
        	if (cnt.stopMeasurement) {
        		return;// drop out of spinning if the benchmark iteration is done
        	}
        }
    	Ping element = lProducer.currentElement();
        element.setValue(writeValue);
        lProducer.commit();
    }
JMH Test to measure throughput for a tiny message with an SPSC Channel.

To run this benchmark:

java -jar target/microbenchmarks.jar ".*.SpscPingPongThroughputTest.*"
jctools-benchmarks/src/main/java/org/jctools/jmh/throughput/channels/SpscChannelThroughputTest.java