package disruptor | |
import "sync/atomic" | |
func (this *Sequence) Store(value int64) { | |
atomic.StoreInt64(&(*this)[SequencePayloadIndex], value) | |
} | |
func (this *Sequence) Load() int64 { | |
return atomic.LoadInt64(&(*this)[SequencePayloadIndex]) | |
} | |
const FillCPUCacheLine uint8 = 8 // TODO: how big is the cache line for i386? |