gistfile1.js

var pools = {};

var Pool = {
    running: false,
    jobs: [],

    append: function(func) {
        var runFunc = function() {
            while (jobs.length > 0) {
                var job = jobs.shift();

                if (job != null) {
                    job();
                }
            }

            running = false;
        };
        jobs.push(func);

        if (!running) {
            running = true;

            var fiber = Fiber(runFunc);
            fiber.run();
        }
    }
};

var addJob = function(func, channel) {
    channel = channel || '';

    if (pools[channel] === undefined) {
        pools[channel] = new Pool();
    }

    pools[channel].append(func);
};

module.exports.addJob = addJob;