Removed unnecessary decoration of constants with specific type; removed variadic constructor.
diff --git a/.gitignore b/.gitignore
index 9efa482..128471c 100644
--- a/.gitignore
+++ b/.gitignore
@@ -1 +1,2 @@
-go-disruptor
+/example/go-disruptor
+/example/example
diff --git a/barrier.go b/barrier.go
index 62f71b4..6c6de78 100644
--- a/barrier.go
+++ b/barrier.go
@@ -2,7 +2,7 @@
type Barrier []*Sequence
-func NewBarrier(upstream ...*Sequence) Barrier {
+func NewBarrier(upstream []*Sequence) Barrier {
buffer := make([]*Sequence, len(upstream))
copy(buffer, upstream)
return Barrier(buffer)
diff --git a/example/main.go b/example/main.go
index eb8875f..75fafff 100644
--- a/example/main.go
+++ b/example/main.go
@@ -6,16 +6,16 @@
"github.com/smartystreets/go-disruptor"
)
-const MaxConsumers int = 1
+const MaxConsumers = 1
func main() {
runtime.GOMAXPROCS(MaxConsumers + 1)
producerSequence := disruptor.NewSequence()
- producerBarrier := disruptor.NewBarrier(producerSequence)
+ producerBarrier := disruptor.NewBarrier([]*disruptor.Sequence{producerSequence})
consumers := startConsumers(producerBarrier, producerSequence)
- consumerBarrier := disruptor.NewBarrier(consumers...)
+ consumerBarrier := disruptor.NewBarrier(consumers)
sequencer := disruptor.NewSingleProducerSequencer(producerSequence, RingSize, consumerBarrier)
publish(sequencer)
@@ -27,5 +27,5 @@
go consume(barrier, sequence, sequence)
}
- return
+ return consumers
}
diff --git a/sequence.go b/sequence.go
index 40a2e4a..e9a3761 100644
--- a/sequence.go
+++ b/sequence.go
@@ -1,9 +1,9 @@
package disruptor
const (
+ InitialSequenceValue = -1
+ cpuCacheLinePadding = 7
MaxSequenceValue int64 = (1 << 63) - 1
- InitialSequenceValue int64 = -1
- cpuCacheLinePadding uint8 = 7
)
type Sequence struct {
diff --git a/worker.go b/worker.go
index 0d96a5a..e6fd990 100644
--- a/worker.go
+++ b/worker.go
@@ -1,8 +1,8 @@
package disruptor
const (
- Gating int64 = -2
- Idle = -3
+ Gating = -2
+ Idle = -3
)
type Worker struct {
