Lines Matching refs:concurrency
7949 function baseQueue(isQueue, worker, concurrency, payload) { argument
7950 if (concurrency === undefined) {
7951 concurrency = 1;
7952 } else if (isNaN(concurrency) || concurrency < 1) {
7962 concurrency: concurrency, property
7966 buffer: concurrency / 4,
8076 if (workers <= q.concurrency - q.buffer) {
8088 while (!q.paused && workers < q.concurrency && q._tasks.length) {
8095 if (workers === q.concurrency) {
8104 while (!q.paused && workers < q.concurrency && q._tasks.length) {
8117 if (workers === q.concurrency) {
8154 var count = q.concurrency < q._tasks.length ? q.concurrency : q._tasks.length;
8170 function queue(worker, concurrency) { argument
8171 return baseQueue(true, worker, concurrency);
8178 function priorityQueue(worker, concurrency) { argument
8179 var q = baseQueue(true, worker, concurrency);
8233 function auto(tasks, concurrency, callback) { argument
8234 if (typeof concurrency === func) {
8235 callback = concurrency;
8236 concurrency = null;
8248 concurrency = concurrency || rest;
8328 while (readyTasks.length && runningTasks < concurrency && callback !== noop) {
8375 function autoInject(tasks, concurrency, callback) { argument
8378 auto(newTasks, concurrency, callback);