Searched refs:execQueue (Results 1 – 9 of 9) sorted by relevance
23 type execQueue struct { struct31 func newExecQueue(capacity int) *execQueue {32 q := &execQueue{funcs: make([]func(), 0, capacity)}38 func (q *execQueue) loop() { argument45 func (q *execQueue) waitNext(drop bool) (f func()) { argument63 func (q *execQueue) isClosed() bool { argument68 func (q *execQueue) canQueue() bool { argument76 func (q *execQueue) queue(f func()) bool { argument89 func (q *execQueue) quit() { argument
69 sendQueue *execQueue
51 func (s *schedulerImpl) Tick(tickTime time.Time, execQueue chan *Job) {61 s.enqueue(job, execQueue)75 s.enqueue(job, execQueue)81 func (s *schedulerImpl) enqueue(job *Job, execQueue chan *Job) {83 execQueue <- job
35 execQueue chan *Job member63 e.execQueue = make(chan *Job, 1000)104 e.scheduler.Tick(tick, e.execQueue)117 case job := <-e.execQueue:
16 Tick(time time.Time, execQueue chan *Job)
97 PuzzleList *tmp = scope.execQueue; in execScope()98 scope.execQueue = scope.scopeQueue; in execScope()113 …for (PuzzleList::iterator PuzzleIter = scope.execQueue->begin(); PuzzleIter != scope.execQueue->en… in execScope()294 scope.execQueue = &scope.privQueueTwo; in cleanScriptScope()
157 PuzzleList *execQueue; // Switch to it when execute member
109 PuzzleList *tmp = scope.execQueue; in execScope()110 scope.execQueue = scope.scopeQueue; in execScope()125 …for (PuzzleList::iterator PuzzleIter = scope.execQueue->begin(); PuzzleIter != scope.execQueue->en… in execScope()308 scope.execQueue = &scope.privQueueTwo; in cleanScriptScope()