Github user Ethanlm commented on a diff in the pull request:
https://github.com/apache/storm/pull/2641#discussion_r183399450
--- Diff:
examples/storm-perf/src/main/java/org/apache/storm/perf/JCToolsPerfTest.java ---
@@ -19,25 +19,24 @@
package org.apache.storm.perf;
import java.util.concurrent.locks.LockSupport;
-
import org.apache.storm.utils.MutableLong;
import org.jctools.queues.MpscArrayQueue;
public class JCToolsPerfTest {
public static void main(String[] args) throws Exception {
-// oneProducer1Consumer();
-// twoProducer1Consumer();
-// threeProducer1Consumer();
-// oneProducer2Consumers();
-// producerFwdConsumer();
-
-// JCQueue spoutQ = new JCQueue("spoutQ", 1024, 100, 0);
-// JCQueue ackQ = new JCQueue("ackQ", 1024, 100, 0);
-//
-// final AckingProducer ackingProducer = new AckingProducer(spoutQ,
ackQ);
-// final Acker acker = new Acker(ackQ, spoutQ);
-//
-// runAllThds(ackingProducer, acker);
+ // oneProducer1Consumer();
+ // twoProducer1Consumer();
+ // threeProducer1Consumer();
+ // oneProducer2Consumers();
+ // producerFwdConsumer();
--- End diff --
nit: spaces between `//` and code
---
