Remove debugging code and redundant gating sequence.

xzknet · Sep 28, 2016 · 7d6c7d7 · 7d6c7d7
1 parent 2ac22c1
commit 7d6c7d7
Show file tree

Hide file tree

Showing 2 changed files with 0 additions and 7 deletions.
diff --git a/src/main/java/com/lmax/disruptor/WorkerPool.java b/src/main/java/com/lmax/disruptor/WorkerPool.java
@@ -95,7 +95,6 @@ public WorkerPool(
                 workSequence);
         }
 
-        ringBuffer.addGatingSequences(workSequence);
         ringBuffer.addGatingSequences(getWorkerSequences());
     }
 

diff --git a/src/test/java/com/lmax/disruptor/WorkerStressTest.java b/src/test/java/com/lmax/disruptor/WorkerStressTest.java
@@ -142,11 +142,6 @@ public void run()
                     testEvent.b = next - 7;
                     testEvent.s = "wibble-" + next;
                     ringBuffer.publish(next);
-
-                    if ((next + 1) % 1000 == 0)
-                    {
-                        System.out.printf("Published: %d%n", next + 1);
-                    }
                 }
             }
             catch (Exception e)
@@ -156,7 +151,6 @@ public void run()
             finally
             {
                 shutdownLatch.countDown();
-                System.out.println("Released latch: " + shutdownLatch.getCount());
             }
         }
     }
-Original file line number
+Diff line change
@@ Expand Up / @@ -95,7 +95,6 @@ public WorkerPool( @@
                     workSequence);
             }
-            ringBuffer.addGatingSequences(workSequence);
             ringBuffer.addGatingSequences(getWorkerSequences());
         }
@@ Expand Down @@