Introducing Socket Firewall: Free, Proactive Protection for Your Software Supply Chain.Learn More
Socket
Book a DemoInstallSign in
Socket

taskwork

Package Overview
Dependencies
Maintainers
1
Versions
5
Alerts
File Explorer

Advanced tools

Socket logo

Install Socket

Detect and block malicious and high-risk dependencies

Install

taskwork

Efficient multi-threaded task scheduler using generic re-usable WebWorkers.

latest
Source
npmnpm
Version
0.0.5
Version published
Maintainers
1
Created
Source

Taskwork

npm version gzip size install size

Efficient multi-threaded task scheduler for the browser using generic re-usable WebWorkers.

Taskwork is a task scheduler that is able to delegate tasks to WebWorkers. These WebWorkers are special in the sense that they are able to execute and return the results from arbitrary tasks send to them. At the start of the application a fixed amount of threads are spawned and re-used throughout the lifetime of the application. This has the advantage of paying the spawn-cost of WebWorkers (~45 ms) and the overhead of spawning only once.

Another feature of Taskwork is the ability to schedule a task with a certain priority. By automatically min-sorting the task queue based on priority we can make sure that tasks with the highest priority are executed first. This is important because the goal is to stay within the frameTarget (by default 60 fps) frame budget. Taskwork internally checks wether there is enough time left in the frame to run a task and automatically defers it to the next frame if there is not.

Status

UNSTABLE, IN-PROGRESS

ONLY SUPPORTED IN BROWSER

Installation

Make sure you have Node.js installed.

 $ npm install taskwork

Usage

// Priorities is just an enum with default levels, you can use your own
import { Priorities, Scheduler } from 'taskwork';

// Any function, sync or async (this will be serialized and executed inside of a WebWorker)
const getUser = async (username: string) => {
  const url = `https://api.github.com/users/${username}`;
  const res = await fetch(url);
  const profile = await res.json();
  return profile.name;
};

const scheduler = new Scheduler({
  frameBudget?: number; // (Default, 1.0) Percentage of frame budget to allow for task execution
  threadCount?: number; // (Default, 2 - 4 depending on CPU architecture) Amount of threads to spawn
});

async () => {
  // Gets executed on first thread, returns a Promise<result>
  const taskAp = scheduler.addTask(Priorities.LowPriority, getUser, [
    'microsoft',
  ]);
  // Gets executed on second thread, returns a Promise<result>
  const taskBp = scheduler.addTask(Priorities.ImmediatePriority, getUser, [
    'timvanscherpenzeel',
  ]);

  // Await results
  const taskA = await taskAp;
  const taskB = await taskBp;

  console.log(taskA, taskB); // -> 'Microsoft', 'Tim van Scherpenzeel'
};

Licence

My work is released under the MIT license.

Keywords

task

FAQs

Package last updated on 26 Oct 2020

Did you know?

Socket

Socket for GitHub automatically highlights issues in each pull request and monitors the health of all your open source dependencies. Discover the contents of your packages and block harmful activity before you install or update your dependencies.

Install

Related posts