Node.js Task & Worker

taskforce.js

'use strict';

const _ = require('underscore');

function Task(fn) {
  this.fn = fn;
}

function Worker(interval, tasks) {
  this.interval = interval;
  this.tasks = tasks || [];
  this._timers = [];

  this.start = tick => {
    let tasks = _.isFunction(tick) ? [tick, ...this.tasks] : this.tasks;
    this._timers = _.map(tasks, task => setInterval(task, this.interval));
  };
  this.stop = () => {
    _.each(this._timers, timer => clearInterval(timer));
  };
}

module.exports = {
  Task: Task,
  Worker: Worker
};