| package main |
| |
| func (this Barrier) Load(consumer int) int64 { |
| minimum := MaxSequenceValue |
| |
| for i := 0; i < len(this); i++ { |
| cursor := this[i].Load() |
| |
| // if len(this) > 1 { |
| // fmt.Printf("Producer:: Consumer %d Barrier: %d\n", i+1, cursor) |
| // } else { |
| // fmt.Printf("\t\t\t\t\t\t\t\t\tConsumer %d:: Producer Barrier: %d\n", consumer, cursor) |
| // } |
| |
| if cursor < minimum { |
| minimum = cursor |
| } |
| } |
| |
| return minimum |
| } |
| |
| func NewBarrier(upstream ...*Sequence) Barrier { |
| this := Barrier{} |
| for i := 0; i < len(upstream); i++ { |
| this = append(this, upstream[i]) |
| } |
| return this |
| } |
| |
| type Barrier []*Sequence |
