Lines Matching refs:concurrency
1024 function auto(tasks, concurrency, callback) { argument
1025 if (typeof concurrency !== 'number') {
1027 callback = concurrency;
1028 concurrency = null;
1035 if (!concurrency) {
1036 concurrency = numTasks;
1099 while(readyTasks.length && runningTasks < concurrency) {
1458 function queue(worker, concurrency, payload) { argument
1459 if (concurrency == null) {
1460 concurrency = 1;
1462 else if(concurrency === 0) {
1564 if (numRunning <= (q.concurrency - q.buffer) ) {
1610 concurrency, property
1612 buffer: concurrency / 4,
1657 while(!q.paused && numRunning < q.concurrency && q._tasks.length){
1674 if (numRunning === q.concurrency) {
1834 function cargo$1(worker, concurrency, payload) { argument
1835 return queue(worker, concurrency, payload);
4013 function queue$1 (worker, concurrency) { argument
4017 }, concurrency, 1);
4160 function priorityQueue(worker, concurrency) { argument
4162 var q = queue$1(worker, concurrency);