Changeset 541 for Tests

Timestamp:

04/10/12 14:39:18 (10 years ago)

Author:

BegemoT

Message:

 

Location:

Tests/JAVA/test/src/main/java

Files:

• com/lmax/disruptor/Sequence.java (modified) (3 diffs)
• com/lmax/disruptor/UnpaddedSingleThreadedClaimStrategy.java (added)
• test/threads/queue/unstressed/DisruptorTask.java (modified) (1 diff)

Tests/JAVA/test/src/main/java/com/lmax/disruptor/Sequence.java

@@ -1 +1 @@
 package com.lmax.disruptor;
+
+import java.util.concurrent.atomic.AtomicLong;
 
 import com.lmax.disruptor.util.PaddedAtomicLong;
@@ -10 +12 @@
 public class Sequence {
     private final PaddedAtomicLong value = new PaddedAtomicLong( Sequencer.INITIAL_CURSOR_VALUE );
+//    private final AtomicLong value = new AtomicLong( Sequencer.INITIAL_CURSOR_VALUE );
 
     /** Default Constructor that uses an initial value of {@link com.lmax.disruptor.Sequencer#INITIAL_CURSOR_VALUE}.*/
@@ -28 +31 @@
     }
 
-    public void set( final long value ) {
-//        this.value.set( value );
-        this.value.lazySet( value );
+    public void set( final long _value ) {
+//        this.value.set( _value );
+        this.value.lazySet( _value );
     }
-
-    /*private volatile long value;
-    public volatile long p1, p2, p3, p4, p5, p6 = 7L;
-
-    public Sequence() {
-        this( Sequencer.INITIAL_CURSOR_VALUE );
-    }
-
-    public Sequence( final long initialValue ) {
-        this.value = initialValue;
-    }
-
-    public long get() {
-        return value;
-    }
-
-    public void set( final long value ) {
-        this.value = value;
-    }
-
-    public long sumPaddingToPreventOptimisation() {
-        return p1 + p2 + p3 + p4 + p5 + p6;
-    }*/
 }

Tests/JAVA/test/src/main/java/test/threads/queue/unstressed/DisruptorTask.java

@@ -127 +127 @@
         }
 
-        sumAfterGaps += ringBuffer.getCursor() - lastSequence.get();
+        final long gap = ringBuffer.getCursor() - lastSequence.get();
+        sumAfterGaps += gap;
         gapsMeasured++;
+
+        /*if ( gap < 4 ) {
+            Thread.yield();
+        }*/
         return sum;
     }