Add worker-task-queue package

Author: developit

.gitignore

@@ -1,4 +1,5 @@
-/package-lock.json
-/node_modules
-/dist
+package-lock.json
+node_modules
+dist
 /polyfill
+/packages/worker-task-queue/processor

package.json

@@ -7,7 +7,9 @@
   "umd:main": "dist/task-worklet.js",
   "module": "dist/task-worklet.module.js",
   "scripts": {
-    "build": "microbundle -f umd,es && microbundle -f iife src/polyfill.mjs -o polyfill/index.js",
+    "build": "npm run -s build:main && npm run -s build:wtq",
+    "build:main": "microbundle -f umd,es && microbundle -f iife src/polyfill.js -o polyfill/index.js",
+    "build:wtq": "cd packages/worker-task-queue && npm run -s build",
     "test": "eslint \"{src,test}/**/*.test.{mjs,js}\" && karmatic --no-headless"
   },
   "files": [

packages/worker-task-queue/README.md

@@ -0,0 +1,36 @@
+# `worker-task-queue`
+
+This is a standalone implementation of the cooperative multithreading model from [Task Worklet](https://github.com/developit/task-worklet) as a zero-dependency library for Web and Node.
+
+```js
+import WorkerTaskQueue from 'worker-task-queue';
+
+// Set up the worker pool
+const queue = new WorkerTaskQueue({
+  // URL/path for our worker script:
+  workerUrl: '/path/to/worker.js',
+  // max pool size:
+  size: 4
+});
+
+function demo(image) {
+  // allocates a thread in the pool doesn't have one free:
+  const cropped = postTask('crop', image, { box: [10, 20, 30, 40] });
+
+  // subsequent tasks run on the same thread to eliminate data transfer:
+  let large = postTask('resize', cropped, { width: 1000, height: 1000 });
+  large = postTask('compress', large, quality);
+
+  // ... except when they get automatically parallelized by moving the input to a second thread:
+  let thumb = postTask('resize', cropped, { width: 200, height: 200 });
+  thumb = postTask('compress', thumb, quality);
+
+  // At this point we've only transferred one image to a background thread,
+  // and transferred another image between two threads.
+
+  // Only the final results are transferred back here, and only when we ask for them:
+  showPreview(await large.result, await thumb.result);
+}
+
+demo();
+```

packages/worker-task-queue/package.json

@@ -0,0 +1,31 @@
+{
+  "name": "worker-task-queue",
+  "version": "0.1.0",
+  "description": "Streamlined processing of tasks in a shared threadpool.",
+  "module": "dist/worker-task-queue.module.js",
+  "main": "dist/worker-task-queue.js",
+  "umd:main": "dist/worker-task-queue.umd.js",
+  "scripts": {
+    "build": "microbundle src/index.ts -f es,cjs,umd && microbundle -f es,cjs,umd src/processor.ts -o processor/index.js"
+  },
+  "files": [
+    "dist",
+    "processor",
+    "src"
+  ],
+  "repository": "developit/task-worklet",
+  "keywords": [
+    "tasks",
+    "task worklet",
+    "worker task queue",
+    "task queue",
+    "parallelization",
+    "off-main-thread",
+    "OMT",
+    "threads",
+    "multithreading"
+  ],
+  "author": "Jason Miller <developit@google.com>",
+  "license": "Apache-2.0",
+  "homepage": "https://github.com/developit/task-worklet/packages/worker-task-queue"
+}