clusterun

Run tasks in cluster mode easily.

Installation

$ npm install clusterun --save

Usage

function clusterun

Master => Workers => Master

const { clusterun, registerTask, dispatchTask } = require('clusterun');

const runner = function () {
    // run by Master, to create tasks and dispatch them to Workers
};

const handler = async function (taskName, taskData) {
    let result;
    // run by Workers, to process tasks and produce results
    return result;
};

const callback = function (taskName, taskSourceData, taskResultData) {
    // run by Master, to handle task results
};

clusterun(runner, handler, callback, {
    clusterNumber: 2, // number of clusters; optional; default: number of CPU
    autoRestart: true, // whether to restart a dead Worker automatically; optional; default: false
});

function registerTask

Register a type of task, with a hash-of-task-data function. Called by Master.

registerTask('my-computing-task', aHashCodeFunctionForTaskData);

function dispatchTask

Dispatch a task to Worker. Called by Master.

dispatchTask('my-computing-task', taskData);

helper functions

name | function | usage :---: | :--- | :--- whoami | check the role of the current process, and output logs if any | role = whoami() whoami('computing task A') ifMaster | run if the current is Master | ifMaster() && doSth() ifMaster(doSth) ifWorker | run if the current is Worker | ifWorker() && doSth() ifWorker(doSth)

License

MIT