blob: e9d2211c36f9e614213bd05b58ae3db01f8e3d99 [file] [log] [blame]
package disruptor
type CompositeBarrier struct {
cursors []*Cursor
}
func NewCompositeBarrier(upstream ...*Cursor) *CompositeBarrier {
if len(upstream) == 0 {
panic("At least one upstream cursor is required.")
}
cursors := make([]*Cursor, len(upstream))
copy(cursors, upstream)
return &CompositeBarrier{cursors}
}
func (this *CompositeBarrier) LoadBarrier(current int64) int64 {
minimum := MaxSequenceValue
for _, item := range this.cursors {
sequence := item.Load()
if sequence < minimum {
minimum = sequence
}
}
return minimum
}