| package disruptor |
| |
| type CompositeBarrier []*Cursor |
| |
| // 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} |
| return CompositeBarrier(cursors) |
| } |
| |
| func (this CompositeBarrier) Read(noop int64) int64 { |
| minimum := MaxSequenceValue |
| // for _, item := range this.cursors { |
| for _, item := range this { |
| sequence := item.Load() |
| if sequence < minimum { |
| minimum = sequence |
| } |
| } |
| |
| return minimum |
| } |
