jankyqueue

This is a complete knuckle-dragger remedial queue class. I use step to organize async stuff, and it doesn't have queueing built in. So I made this and I use it and now I'm sharing it with you and if you don't like it you can go use something else.

Licence

Copyright 2012, E14N Inc.

Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at

http://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.

Overview

You can get to the Queue class by requiring jankyqueue.

var Queue = require("jankyqueue");

You can make a new queue like this:

var q = new Queue(10);

This makes a queue which can have 10 things going at the same time. To do something, use the enqueue method.

// an async function

var myfunc = function(param1, param2, callback) {
    process.nextTick(function() {
        callback(null, param1 + param2);
    });
};

var arg1 = 23,
    arg2 = 42;
    
q.enqueue(myfunc, [arg1, arg2], function(err, result) {
    if (err) {
        console.error(err);
    } else {
        console.log(result);
    }
});

API

• new Queue(len)

  Makes a new queue with length len. No more than len operations will run at the same time.

• enqueue(fn, args, callback)

  Enqueues an operation -- calling function fn on the array of arguments args, and returning the results to callback.

  If there aren't other operations running, it will run immediately; if there are, it will wait until another one is done.