1 Star 0 Fork 2

王布衣/pkg

加入 Gitee
与超过 1200万 开发者一起发现、参与优秀开源项目,私有仓库也完全免费 :)
免费加入
文件
克隆/下载
interfaces.go 418 Bytes
一键复制 编辑 原始数据 按行查看 历史
package fastqueue
import "errors"
var (
ErrMinimumReservationSize = errors.New("the minimum reservation size is 1 slot")
)
type Consumer interface {
Consume(lower, upper int64)
}
type Barrier interface {
Load() int64
}
type WaitStrategy interface {
Gate(int64)
Idle(int64)
}
type Writer interface {
Reserve(count int64) int64
Commit(lower, upper int64)
}
type Reader interface {
Read()
Close() error
}
马建仓 AI 助手
尝试更多
代码解读
代码找茬
代码优化
1
https://gitee.com/quant1x/pkg.git
git@gitee.com:quant1x/pkg.git
quant1x
pkg
pkg
v0.2.1

搜索帮助

0d507c66 1850385 C8b1a773 1850385