queue := NewQueue(8) ok := queue.Put(1) val, ok := queue.Get()
// block at least 50ms ok = queue.PutWait(2, time.Second) val, ok = queue.GetWait(time.Second)
ring queue, support multiple reads and writes,lock free
| Name | Name | Last commit message | Last commit date | |
|---|---|---|---|---|
Latest commit | ||||
ring queue, support multiple reads and writes,lock free