Class CounterBench

core/src/test/java/org/apache/sirona/counters/CounterBench.java:29–61

import static org.junit.Assert.assertEquals;

public class CounterBench implements Runnable {
    private static final int THREADS = 30;
    private static final int LOOPS = 20000000;

    private Counter counter;
    private String mode;

    @Test
    public void defaultCounter() throws Exception {
        mode = "RentrantLockCounter";
        counter = new DefaultCounter(new Counter.Key(Role.FAILURES, mode), new InMemoryCounterDataStore());
        runConcurrent();
    }

    private void runConcurrent() throws InterruptedException {
        final long start = System.nanoTime();
        final ExecutorService pool = Executors.newFixedThreadPool(THREADS);
        for (int i = 0; i < LOOPS; i++) {
            pool.submit(this);
        }
        pool.shutdown();
        pool.awaitTermination(60, TimeUnit.SECONDS);

        final long duration = System.nanoTime() - start;
        System.out.printf("%s : %,d ns/operation %n\n", mode, duration / LOOPS);
        assertEquals(LOOPS, counter.getSum(), 0);

    }

    public void run() {
        counter.add(1, Unit.UNARY);
    }
}