Changeset 591 for Tests

Timestamp:

12/08/13 19:21:50 (8 years ago)

Author:

BegemoT

Message:

 

Location:

Tests/JAVA/logger

Files:

• atomics-results.csv (added)
• scripts (added)
• scripts/plots.r (added)
• src/main/java/com/db/logger/benchmarks/helpers/AtomicBenchmark.java (modified) (5 diffs)
• src/main/java/com/db/logger/benchmarks/helpers/SequencerBenchmark.java (modified) (2 diffs)
• src/main/java/com/db/logger/benchmarks/helpers/UnsafeAtomicBenchmark.java (modified) (6 diffs)

Tests/JAVA/logger/src/main/java/com/db/logger/benchmarks/helpers/AtomicBenchmark.java

@@ -3 +3 @@
 import java.util.concurrent.TimeUnit;
 import java.util.concurrent.atomic.AtomicInteger;
+import java.util.concurrent.atomic.AtomicLong;
 
 import org.openjdk.jmh.annotations.*;
@@ -21 +22 @@
         }
 
-        //TODO use Unsafe for paiding
-        public AtomicInteger counter;
+        public AtomicLong counter;
 
         @Setup
         public void setup() {
-                counter = new AtomicInteger( 0 );
+                counter = new AtomicLong( 0 );
         }
 
@@ -42 +42 @@
         @GenerateMicroBenchmark
         @Group( "payload" )
+        @GroupThreads( 4 )
         public void backoffAlone() {
                 BlackHole.consumeCPU( WRITER_BACKOFF );
@@ -49 +50 @@
         @GenerateMicroBenchmark
         @Group( "writeAlone" )
-        @GroupThreads( 1 )
-        public long writerSolo() {
+        @GroupThreads( 4 )
+        public long writerSolo(final ThreadState ts) {
                 BlackHole.consumeCPU( WRITER_BACKOFF );
-                return counter.incrementAndGet();
+                return ts.counter.incrementAndGet();
         }
 
@@ -112 +113 @@
                 return counter.get();
         }
+
+        @State( Scope.Thread )
+        public static class ThreadState {
+                public volatile AtomicLong counter = new AtomicLong();
+
+        }
         /*=============================================================================*/
 

Tests/JAVA/logger/src/main/java/com/db/logger/benchmarks/helpers/SequencerBenchmark.java

@@ -29 +29 @@
         public static final int WRITER_BACKOFF = Integer.getInteger( "writer-backoff", 7 );
 
-        public static final WaitingStrategy WAITING_STRATEGY = new WaitingStrategy.LimitedSpinning( 1024 * 1024 );
+        public static final WaitingStrategy WAITING_STRATEGY = new WaitingStrategy.LimitedSpinning( 1024 * 128 );
 
         static {
@@ -67 +67 @@
         @GenerateMicroBenchmark
         @Group( "payload" )
+        @GroupThreads( 4 )
         public void backoffAlone() {
                 BlackHole.consumeCPU( WRITER_BACKOFF );

Tests/JAVA/logger/src/main/java/com/db/logger/benchmarks/helpers/UnsafeAtomicBenchmark.java

@@ -3 +3 @@
 import java.lang.reflect.Field;
 import java.util.concurrent.TimeUnit;
+import java.util.concurrent.atomic.AtomicInteger;
+import java.util.concurrent.atomic.AtomicLong;
 
 import com.db.logger.api.impl.logger.UnsafeHelper;
@@ -38 +40 @@
         }
 
-        public volatile int counter;
+        public volatile long counter;
 
         @Setup
@@ -57 +59 @@
         public long incrementAndGet() {
                 for(; ; ) {
-                        int current = counter;
-                        int next = current + 1;
+                        long current = counter;
+                        long next = current + 1;
                         if( UNSAFE.compareAndSwapLong( this, counterOffset, current, next ) ) {
                                 return next;
@@ -68 +70 @@
         @GenerateMicroBenchmark
         @Group( "payload" )
+        @GroupThreads( 4 )
         public void backoffAlone() {
                 BlackHole.consumeCPU( WRITER_BACKOFF );
@@ -75 +78 @@
         @GenerateMicroBenchmark
         @Group( "writeAlone" )
-        @GroupThreads( 1 )
-        public long writerSolo() {
+        @GroupThreads( 4 )
+        public long writerSolo( final ThreadState ts ) {
                 BlackHole.consumeCPU( WRITER_BACKOFF );
-                return incrementAndGet();
+                return ts.counter.incrementAndGet();
         }
 
@@ -140 +143 @@
         /*=============================================================================*/
 
+        @State( Scope.Thread )
+        public static class ThreadState {
+                public volatile AtomicLong counter = new AtomicLong();
+
+        }
+
 
         public static void main( final String[] args ) throws Exception {