Skip to content
This repository

HTTPS clone URL

Subversion checkout URL

You can clone with HTTPS or Subversion.

Download ZIP

Really janky queue class

branch: master

Fetching latest commit…

Octocat-spinner-32-eaf2f5

Cannot retrieve the latest commit at this time

Octocat-spinner-32 lib
Octocat-spinner-32 test
Octocat-spinner-32 .gitignore
Octocat-spinner-32 .travis.yml
Octocat-spinner-32 LICENSE
Octocat-spinner-32 README.md
Octocat-spinner-32 package.json
README.md

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.

Something went wrong with that request. Please try again.