universal-thread-pool

Universal thread pool 通用线程池

适用于 CPU 密集型的任务的通用线程池

可以与 comlink 配合使用实现,浏览器或者deno的web worker 线程池,或者 nodejs的 worker_threads 线程池

https://www.npmjs.com/package/comlink

导入模块

import {} from "https://deno.land/x/masx200_universal_thread_pool@1.0.1/mod.ts";

`createThreadPool`:创建线程池,

接受参数create:创建抽象线程的函数

接受参数terminate:结束抽象线程的函数

接受参数maxThreads:线程池中最多的线程数，默认为cpu个数

`ThreadPool`线程池接口

destroy:销毁线程池中所有线程

run:在线程池中使用一个线程运行指定的callback回调函数,并返回结果,可选第二个参数signal可以使用AbortSignal来提前终止线程的运行.

threads:可以查看所有的线程.

查看 web worker 例子

https://github.com/masx200/universal-thread-pool/tree/main/test/test.ts

最简单的例子

模拟一个抽象线程，使用线程池运行函数，然后销毁线程池

function sleep(timeout: number): Promise<void> {
    return new Promise<void>((resolve) => {
        setTimeout(() => {
            resolve();
        }, timeout);
    });
}
function create() {
let terminated=false
        return {
            terminate() {
                terminated=true
            },
            async echo(a: number): Promise<number> {
if(terminated){throw Error("terminated")}
                await sleep(100);
                return a;
            },
        };
    }
const pool = createThreadPool({
    create,
    terminate(w) {
        w.terminate();
    },
});

const r = await Promise.all(
    Array(10)
        .fill(0)
        .map((_v, i) => pool.run((w) => w.echo(i))),
);
assertEquals(
    r,
    Array(10)
        .fill(0)
        .map((_v, i) => i),
);
pool.destroy();