Skip to main content
Home
Browse packagesDocsSign in

@mys/worker-fn@3.2.1
Built and signed on GitHub Actions

latest
mys1024/worker-fn

worker-fn hides the complexity of communication between the JavaScript main thread and Worker threads, making it easy to call the functions defined in workers.

This package works with Node.js, Deno, BrowsersIt is unknown whether this package works with Cloudflare Workers, Bun
It is unknown whether this package works with Cloudflare Workers
This package works with Node.js
This package works with Deno
It is unknown whether this package works with Bun
This package works with Browsers
JSR Score
100%
Published
a year ago (3.2.1)

worker-fn

jsr-version npm-version npm-minzip docs stars license

workflow-ci workflow-release

English | 中文文档

worker-fn hides the complexity of communication between the JavaScript main thread and Worker threads, making it easy to call the functions defined in workers.

worker-fn allows you to create proxy functions in the main thread that call corresponding worker functions defined in worker threads by sending messages. These proxy functions maintain the same function signatures as the corresponding worker functions (except that the return values of the proxy functions are wrapped in Promises).

concepts

Usage

Basic

math.worker.js:

import { defineWorkerFn } from "worker-fn";

function add(a, b) {
  return a + b;
}

function fib(n) {
  return n <= 2 ? 1 : fib(n - 1) + fib(n - 2);
}

defineWorkerFn("add", add);
defineWorkerFn("fib", fib);

math.js:

import { useWorkerFn } from "worker-fn";

const worker = new Worker(new URL("./math.worker.js", import.meta.url), {
  type: "module",
});

const add = useWorkerFn("add", worker);
const fib = useWorkerFn("fib", worker);

console.log(await add(1, 2)); // 3
console.log(await fib(5)); // 5

Using defineWorkerFns() and useWorkerFns()

Example

math.worker.js:

import { defineWorkerFns } from "worker-fn";

const fns = {
  add(a, b) {
    return a + b;
  },
  fib(n) {
    return n <= 2 ? 1 : fns.fib(n - 1) + fns.fib(n - 2);
  },
};

defineWorkerFns(fns);

math.js:

import { useWorkerFns } from "worker-fn";

const worker = new Worker(new URL("./math.worker.js", import.meta.url), {
  type: "module",
});

const { add, fib } = useWorkerFns(worker);

console.log(await add(1, 2)); // 3
console.log(await fib(5)); // 5

Using with TypeScript

Example

math.worker.ts:

import { defineWorkerFn } from "worker-fn";

function add(a: number, b: number) {
  return a + b;
}

function fib(n: number): number {
  return n <= 2 ? 1 : fib(n - 1) + fib(n - 2);
}

defineWorkerFn("add", add);
defineWorkerFn("fib", fib);

export type Add = typeof add;
export type Fib = typeof fib;

math.ts:

import { useWorkerFn } from "worker-fn";
import type { Add, Fib } from "./math.worker.ts";

const worker = new Worker(new URL("./math.worker.ts", import.meta.url), {
  type: "module",
});

const add = useWorkerFn<Add>("add", worker);
const fib = useWorkerFn<Fib>("fib", worker);

console.log(await add(1, 2)); // 3
console.log(await fib(5)); // 5

Using in Node.js with node:worker_threads

Example

math.worker.js:

import { parentPort } from "node:worker_threads";
import { defineWorkerFn } from "worker-fn";

function add(a, b) {
  return a + b;
}

function fib(n) {
  return n <= 2 ? 1 : fib(n - 1) + fib(n - 2);
}

defineWorkerFn("add", add, { port: parentPort });
defineWorkerFn("fib", fib, { port: parentPort });

math.js:

import { Worker } from "node:worker_threads";
import { useWorkerFn } from "worker-fn";

const worker = new Worker(new URL("./math.worker.js", import.meta.url));

const add = useWorkerFn("add", worker);
const fib = useWorkerFn("fib", worker);

console.log(await add(1, 2)); // 3
console.log(await fib(5)); // 5

Importing from JSR

worker-fn is published on both npm and JSR. If you want to import worker-fn from JSR, please refer to this document.

License

MIT License © 2024-PRESENT mys1024

Built and signed on
GitHub Actions
View transparency log

New Ticket: Report package

Please provide a reason for reporting this package. We will review your report and take appropriate action.

Please review the JSR usage policy before submitting a report.

Add Package

deno add jsr:@mys/worker-fn

Import symbol

import * as worker_fn from "@mys/worker-fn";
or

Import directly with a jsr specifier

import * as worker_fn from "jsr:@mys/worker-fn";

Add Package

pnpm i jsr:@mys/worker-fn
or (using pnpm 10.8 or older)
pnpm dlx jsr add @mys/worker-fn

Import symbol

import * as worker_fn from "@mys/worker-fn";

Add Package

yarn add jsr:@mys/worker-fn
or (using Yarn 4.8 or older)
yarn dlx jsr add @mys/worker-fn

Import symbol

import * as worker_fn from "@mys/worker-fn";

Add Package

vlt install jsr:@mys/worker-fn

Import symbol

import * as worker_fn from "@mys/worker-fn";

Add Package

npx jsr add @mys/worker-fn

Import symbol

import * as worker_fn from "@mys/worker-fn";

Add Package

bunx jsr add @mys/worker-fn

Import symbol

import * as worker_fn from "@mys/worker-fn";