worker.go

package disruptor

const (
	Gating = -2
	Idle   = -3
)

type Worker struct {
	barrier  *Barrier
	handler  Consumer
	source   *Sequence
	sequence *Sequence
}

func NewWorker(barrier *Barrier, handler Consumer, source, sequence *Sequence) *Worker {
	return &Worker{
		barrier:  barrier,
		handler:  handler,
		source:   source,
		sequence: sequence,
	}
}

func (this *Worker) Process() int64 {
	next := this.sequence.Load() + 1
	ready := this.barrier.Load()

	if next <= ready {
		for next <= ready {
			this.handler.Consume(next, ready-next)
			next++
		}

		next--
		this.sequence.Store(next)
		return next
	} else if next <= this.source.Load() {
		return Gating
	} else {
		return Idle
	}
}