Lines Matching refs:worker

1452 function queue(worker, concurrency, payload) {  argument
1460 var _worker = wrapAsync(worker);
1727 * `worker` is in progress, the task is queued until it becomes available. Once
1728 * the `worker` has completed some tasks, each callback of those tasks is
1733 * at a time, cargo passes an array of tasks to a single worker, repeating
1734 * when the worker is finished.
1742 * @param {AsyncFunction} worker - An asynchronous function for processing an array
1770 function cargo(worker, payload) { argument
1771 return queue(worker, 1, payload);
1778 * a `worker` has completed some tasks, each callback of those tasks is
1783 … a time, and [`cargo`]{@link module:ControlFlow.cargo} passes an array of tasks to a single worker,
1793 * @param {AsyncFunction} worker - An asynchronous function for processing an array
1796 * `worker` functions should be run in parallel. If omitted, the concurrency
1828 function cargo$1(worker, concurrency, payload) { argument
1829 return queue(worker, concurrency, payload);
3866 * A queue of tasks for the worker function to complete.
3879 * @property {number} concurrency - an integer for determining how many `worker`
3883 * passed to the worker function at a time. only applies if this is a
3886 * once the `worker` has finished processing the task. Instead of a single task,
3912 * when the last item from the `queue` is given to a `worker`. If the callback
3915 * when the last item from the `queue` has returned from the `worker`. If the
3932 * const q = async.queue(worker, 2)
3953 * `worker`s are in progress, the task is queued until one becomes available.
3954 * Once a `worker` completes a `task`, that `task`'s callback is called.
3961 * @param {AsyncFunction} worker - An async function for processing a queued task.
3965 * `worker` functions should be run in parallel. If omitted, the concurrency
4007 function queue$1 (worker, concurrency) { argument
4008 var _worker = wrapAsync(worker);
4139 * @param {AsyncFunction} worker - An async function for processing a queued task.
4143 * @param {number} concurrency - An `integer` for determining how many `worker`
4154 function priorityQueue(worker, concurrency) { argument
4156 var q = queue$1(worker, concurrency);