Moved constant; attempting different consumer.
diff --git a/example/example_producer.go b/example/example_producer.go
index 3f00a46..4ddd222 100644
--- a/example/example_producer.go
+++ b/example/example_producer.go
@@ -16,5 +16,3 @@
}
}
}
-
-const ItemsToPublish = 4
diff --git a/example/main.go b/example/main.go
index ab1b4be..9299264 100644
--- a/example/main.go
+++ b/example/main.go
@@ -7,7 +7,8 @@
)
const MaxConsumersPerGroup = 1
-const MaxConsumerGroups = 2
+const MaxConsumerGroups = 1
+const ItemsToPublish = 1
func main() {
runtime.GOMAXPROCS(MaxConsumerGroups*MaxConsumersPerGroup + 1)
@@ -35,17 +36,17 @@
reader := disruptor.NewReader(upstreamBarrier, writerCursor, readerCursor)
// constant time regardless of the number of items
- // go consume0(disruptor.NewSimpleReader(reader, NewExampleConsumerHandler()))
+ go consume0(disruptor.NewSimpleReader(reader, NewExampleConsumerHandler()))
// wildly sporadic latency for single-item publish, e.g. 2 seconds, 65 ms, etc.
// faster for 2-3+ items per publish
- // go consume1(reader)
+ //go consume1(reader)
- if group == 0 {
- go consume1(reader)
- } else if group == 1 {
- go consume2(reader)
- }
+ // if group == 0 {
+ // go consume1(reader)
+ // } else if group == 1 {
+ // go consume2(reader)
+ // }
}
return disruptor.NewBarrier(readerCursors...)
