Lines Matching refs:concurrency
391 throw new RangeError('concurrency limit cannot be less than 1')
903 * @param {number} [concurrency=Infinity] - An optional `integer` for
1018 function auto(tasks, concurrency, callback) { argument
1019 if (typeof concurrency !== 'number') {
1020 // concurrency is optional, shift the args.
1021 callback = concurrency;
1022 concurrency = null;
1029 if (!concurrency) {
1030 concurrency = numTasks;
1093 while(readyTasks.length && runningTasks < concurrency) {
1452 function queue(worker, concurrency, payload) { argument
1453 if (concurrency == null) {
1454 concurrency = 1;
1456 else if(concurrency === 0) {
1558 if (numRunning <= (q.concurrency - q.buffer) ) {
1604 concurrency, property
1606 buffer: concurrency / 4,
1651 while(!q.paused && numRunning < q.concurrency && q._tasks.length){
1668 if (numRunning === q.concurrency) {
1776 …* cargoQueue will be processed together (up to the `payload` limit) in `concurrency` parallel work…
1795 * @param {number} [concurrency=1] - An `integer` for determining how many
1796 * `worker` functions should be run in parallel. If omitted, the concurrency
1797 * defaults to `1`. If the concurrency is `0`, an error is thrown.
1806 * // create a cargoQueue object with payload 2 and concurrency 2
1828 function cargo$1(worker, concurrency, payload) { argument
1829 return queue(worker, concurrency, payload);
3879 * @property {number} concurrency - an integer for determining how many `worker`
3881 * `queue` is created to alter the concurrency on-the-fly.
3902 * called when the number of running workers hits the `concurrency` limit, and
3906 * called when the number of running workers is less than the `concurrency` &
3951 * Creates a `queue` object with the specified `concurrency`. Tasks added to the
3952 * `queue` are processed in parallel (up to the `concurrency` limit). If all
3964 * @param {number} [concurrency=1] - An `integer` for determining how many
3965 * `worker` functions should be run in parallel. If omitted, the concurrency
3966 * defaults to `1`. If the concurrency is `0`, an error is thrown.
3972 * // create a queue object with concurrency 2
4007 function queue$1 (worker, concurrency) { argument
4011 }, concurrency, 1);
4143 * @param {number} concurrency - An `integer` for determining how many `worker`
4144 * functions should be run in parallel. If omitted, the concurrency defaults to
4145 * `1`. If the concurrency is `0`, an error is thrown.
4154 function priorityQueue(worker, concurrency) { argument
4156 var q = queue$1(worker, concurrency);