微缩同步池

这是一个无害环境管理+类型脚本叉 微缩同步池 由Rafael Xavier de Souza出品,带有一些附加功能.

为什么?

该图书馆的目标是使用本地的同声传动器(ES9)、本地的同声传动器和本地的同声传动器来进行并行/争吵的工作.

你说什么?

doWorkAndYield 在有限的货币池中运行多个返回的许诺函数。 一旦其中一项承诺遭到拒绝,它立即予以拒绝。 它尽快(在同币限额下)调用执行器功能. 它返回一个当一个承诺完成时(在同位素限制下)即能产能的同位素。 例如:

const timeout = (ms) =>
  new Promise((resolve) => setTimeout(() => resolve(ms), ms));

for await (const ms of doWorkAndYield(2, [1000, 5000, 3000, 2000], timeout)) {
  console.log(ms);
}
// Call iterator timeout(1000)
// Call iterator timeout(5000)
// Concurrency limit of 2 reached, wait for the quicker one to complete...
// 1000 finishes
// for await...of outputs "1000"
// Call iterator timeout(3000)
// Concurrency limit of 2 reached, wait for the quicker one to complete...
// 3000 finishes
// for await...of outputs "3000"
// Call iterator timeout(2000)
// Itaration is complete, wait until running ones complete...
// 5000 finishes
// for await...of outputs "5000"
// 2000 finishes
// for await...of outputs "2000"

使用量

$ npm install @altano/tiny-async-pool

import { doWorkAndYield } from "@altano/tiny-async-pool";

{\fn华文楷体\fs16\1cHE0E0E0}等待..

for await (const value of doWorkAndYield(concurrency, iterable, iteratorFn)) {
  console.log(value);
}

API 密码

doWorkAndYield(concurrency, iterable, iteratorFn)

在有限的货币池中运行多个许诺回放函数( A) 。 一旦其中一项承诺遭到拒绝,它立即予以拒绝。 它尽快(在同币限额下)调用执行器功能. 它返回一个当一个承诺完成时(在同位素限制下)即能产能的同位素.

货币

通币限额号(>= 1).

可执行

输入 可移动对象,例如 String, (中文(简体) ), Array, (中文(简体) ), TypedArray, (中文(简体) ), Map,以及 Set。 。 。 .

执行者Fn

迭代函数需要两个参数:每个迭代的值和可迭代对象本身. 执行函数要么返回承诺,要么成为同步函数.

doWork(concurrency, iterable, iteratorFn)

喜欢 doWorkAndYield(...) 但有一个简单的API。 当你不在乎返回值时有用 iteratorFn,比如一个工人池,在那里,你做批量的文件提交 工人产生副作用而不是返回一个值.

例如,批量文件擦除器就如同:

const eraseFile = (path) => fs.unlink(path);
const eraseFiles = async (files) => doWork(4, files, eraseFile);

将强制执行: iteratorFn 返回时 Promise<void> 当使用 TypeScript 时.

许可证

麻省理工学院 拉斐尔·扎维尔·德苏扎 麻省理工学院 艾伦·诺鲍尔