Lines Matching defs:fifo
46 type fifo struct { struct
47 mu sync.Mutex
49 resume chan struct{}
50 scheduled int
51 finished int
52 pendings []Job
54 ctx context.Context
55 cancel context.CancelFunc
57 finishCond *sync.Cond
58 donec chan struct{}
75 func (f *fifo) Schedule(j Job) {
92 func (f *fifo) Pending() int {
98 func (f *fifo) Scheduled() int {
104 func (f *fifo) Finished() int {
110 func (f *fifo) WaitFinish(n int) {
119 func (f *fifo) Stop() {
127 func (f *fifo) run() {