Changeset 534 for Tests

Timestamp:

04/03/12 22:05:48 (10 years ago)

Author:

BegemoT

Message:

 

Location:

Tests/JAVA/test

Files:

• config.properties.template (modified) (1 diff)
• src/main/java/test/threads/queue/unstressed/DisruptorTask.java (modified) (4 diffs)

Tests/JAVA/test/config.properties.template

@@ -22 +22 @@
 disruptor.wait-strategy     = com.lmax.disruptor.BusySpinWaitStrategy
 disruptor.publish-in-batch  = false
+disruptor.subscribe-in-batch  = true

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

@@ -22 +22 @@
     private final WaitStrategy waitStrategy;
     private final boolean publishInBatch;
-    private final boolean subsribeInBatch;
+    private final boolean subscribeInBatch;
 
     public DisruptorTask( final Config config ) throws ClassNotFoundException, InstantiationException, IllegalAccessException {
@@ -33 +33 @@
 
         this.publishInBatch = config.getAsBoolean( "disruptor.publish-in-batch", false );
-        this.subsribeInBatch = config.getAsBoolean( "disruptor.subscribe-in-batch", true );
+        this.subscribeInBatch = config.getAsBoolean( "disruptor.subscribe-in-batch", true );
     }
 
@@ -68 +68 @@
 
         long sum = 0;
-        if ( subsribeInBatch ) {
+        if ( subscribeInBatch ) {
             long nextSequence = lastSequence.get() + 1L;
             while ( nextSequence <= maxSequence ) {
@@ -112 +112 @@
     public String toString() {
         return String.format(
-                "%s[%d][%s][%s]",
+                "%s[%d][%s][publish:%s][subscribe:%s]",
                 getClass().getSimpleName(),
                 bufferSize(),
                 waitStrategy.getClass().getSimpleName(),
-                ( publishInBatch ) ? ( "batching" ) : ( "no-batching" )
+                ( publishInBatch ) ? ( "batch" ) : ( "no-batch" ),
+                ( subscribeInBatch ) ? ( "batch" ) : ( "no-batch" )
         );
     }