Changeset 531 for Tests

Timestamp:

04/03/12 16:11:43 (10 years ago)

Author:

BegemoT

Message:

 

File:

• Tests/JAVA/test/src/main/java/test/threads/queue/unstressed/impl/CABSESDLazySetPaddedSpinOptimizedCleanFreeTASUnrolledQueue.java (copied) (copied from Tests/JAVA/test/src/main/java/test/threads/queue/unstressed/impl/CABSESDLazySetPaddedSpinOptimizedCleanFreeUnrolledQueue.java) (4 diffs)

Tests/JAVA/test/src/main/java/test/threads/queue/unstressed/impl/CABSESDLazySetPaddedSpinOptimizedCleanFreeTASUnrolledQueue.java

@@ -15 +15 @@
  * @since 27.09.11,  14:58
  */
-public class CABSESDLazySetPaddedSpinOptimizedCleanFreeUnrolledQueue<T> implements IQueue<T> {
+public class CABSESDLazySetPaddedSpinOptimizedCleanFreeTASUnrolledQueue<T> implements IQueue<T> {
     private static final boolean USE_BITMASK = true;
     //======================================================
-    private static final AtomicLongFieldUpdater<CABSESDLazySetPaddedSpinOptimizedCleanFreeUnrolledQueue> tailUpdater = AtomicLongFieldUpdater.newUpdater( CABSESDLazySetPaddedSpinOptimizedCleanFreeUnrolledQueue.class, "tailCursor" );
-    private static final AtomicLongFieldUpdater<CABSESDLazySetPaddedSpinOptimizedCleanFreeUnrolledQueue> headUpdater = AtomicLongFieldUpdater.newUpdater( CABSESDLazySetPaddedSpinOptimizedCleanFreeUnrolledQueue.class, "headCursor" );
+    private static final AtomicLongFieldUpdater<CABSESDLazySetPaddedSpinOptimizedCleanFreeTASUnrolledQueue> tailUpdater = AtomicLongFieldUpdater.newUpdater( CABSESDLazySetPaddedSpinOptimizedCleanFreeTASUnrolledQueue.class, "tailCursor" );
+    private static final AtomicLongFieldUpdater<CABSESDLazySetPaddedSpinOptimizedCleanFreeTASUnrolledQueue> headUpdater = AtomicLongFieldUpdater.newUpdater( CABSESDLazySetPaddedSpinOptimizedCleanFreeTASUnrolledQueue.class, "headCursor" );
     //======================================================
 
@@ -67 +67 @@
 
 
-    public CABSESDLazySetPaddedSpinOptimizedCleanFreeUnrolledQueue( final int length ) {
+    public CABSESDLazySetPaddedSpinOptimizedCleanFreeTASUnrolledQueue( final int length ) {
         checkArgument( length > 0, "length(%s) must be >0", length );
         if ( USE_BITMASK ) {
@@ -123 +123 @@
 
         final int index = index( newTail );
-        elements[index] = item;
+        if ( elements[index] != item ) {
+            elements[index] = item;
+        }
 
         publishTail( newTail );
@@ -152 +154 @@
 
     @SuppressWarnings( "unchecked" )
-    public static <T> IBoundedQueueFactory<T, CABSESDLazySetPaddedSpinOptimizedCleanFreeUnrolledQueue<T>> factory() {
+    public static <T> IBoundedQueueFactory<T, CABSESDLazySetPaddedSpinOptimizedCleanFreeTASUnrolledQueue<T>> factory() {
         return FACTORY;
     }
 
-    public static final IBoundedQueueFactory FACTORY = new IBoundedQueueFactory<Object, CABSESDLazySetPaddedSpinOptimizedCleanFreeUnrolledQueue<Object>>() {
+    public static final IBoundedQueueFactory FACTORY = new IBoundedQueueFactory<Object, CABSESDLazySetPaddedSpinOptimizedCleanFreeTASUnrolledQueue<Object>>() {
         @Override
-        public CABSESDLazySetPaddedSpinOptimizedCleanFreeUnrolledQueue<Object> create( final int size ) {
-            return new CABSESDLazySetPaddedSpinOptimizedCleanFreeUnrolledQueue<Object>( size );
+        public CABSESDLazySetPaddedSpinOptimizedCleanFreeTASUnrolledQueue<Object> create( final int size ) {
+            return new CABSESDLazySetPaddedSpinOptimizedCleanFreeTASUnrolledQueue<Object>( size );
         }