enqueue.go

func (r *ring) EnqueueRequest(req request) response {
	s := &r.slots[atomic.AddUint64(&r.write, 1)&1023]
	for atomic.CompareAndSwapUint32(&s.mark, 0, 1) {
		runtime.Gosched()
	}
	s.req = req
	atomic.StoreUint32(&s.mark, 2)
	return <-s.ch
}