Lines Matching refs:_tasks
7961 _tasks: new DLL(), property
8001 q._tasks.unshift(item);
8003 q._tasks.push(item);
8015 var _tasks = isArray(tasks) ? tasks : [tasks];
8017 if (tasks === undefined || !_tasks.length) {
8026 arrayEachSync(_tasks, _exec);
8033 q._tasks.empty();
8080 if (q._tasks.length + workers === 0) {
8088 while (!q.paused && workers < q.concurrency && q._tasks.length) {
8089 var task = q._tasks.shift();
8092 if (q._tasks.length === 0) {
8104 while (!q.paused && workers < q.concurrency && q._tasks.length) {
8105 var tasks = q._tasks.splice(q.payload || q._tasks.length);
8114 if (q._tasks.length === 0) {
8126 return q._tasks.length;
8154 var count = q.concurrency < q._tasks.length ? q.concurrency : q._tasks.length;
8162 q._tasks.remove(test);
8187 var _tasks = isArray(tasks) ? tasks : [tasks];
8188 var taskSize = _tasks.length;
8198 var nextNode = q._tasks.head;
8204 data: _tasks[taskSize],
8209 q._tasks.insertBefore(nextNode, item);
8211 q._tasks.push(item);