Nodejs in-process blocking FIFO queue implementation.
Tiny queue data structure
fast, tiny `queueMicrotask` shim for modern engines
A shim for the setImmediate efficient script yielding API
Promise queue with concurrency control
A simple tool to keep requests to be executed in order.
queue-lit is a tiny queue data structure in case you `Array#push()` or `Array#shift()` on large arrays very often
The smallest and simplest JavaScript priority queue
Next tick shim that prefers process.nextTick over queueMicrotask for compat
Offload tasks to a pool of workers on node.js and in the browser
Promise-based queue
LRU Queue
Simple JS queue with auto run for node and browsers
In memory queue system prioritizing tasks
Compile ES2015 block scoping (const and let) to ES5
Allow parsing of class static blocks
Babel plugin to ensure function declarations at the block level are block scoped
The fastest javascript implementation of a double-ended queue. Used by the official Redis, MongoDB, MariaDB & MySQL libraries for Node.js and many other libraries. Maintains compatability with deque.
Simple JS queue with auto run for node and browsers
Transform class static blocks
An implementation of burstable throtling algorithm on top of rxjs
Sequential asynchronous lock-based queue for promises
Fast, in memory work queue
asynchronous function queue with adjustable concurrency
Thread-safe queue and stack data structures with configurable capacity limits, blocking enqueue/dequeue with timeouts, and peek operations. Uses Mutex and ConditionVariable for safe concurrent access.
A dead-simple non-blocking queue.
A Redis-backed pub or processing queue with a non-blocking bar counter
A priority queue is like a standard queue, except that each inserted element is given a certain priority, based on the result of the comparison block given at instantiation time. Retrieving an element from the queue will always return the one with the highest priority.
This roughly mirrors the functionaly of Queue in allowing you to queue messages to one or more threads, and will block if the queue is empty, waking up when there is another message available.
Ensures that for a given queue, only one worker is working on a job at any given time. Example: require 'resque/plugins/lonely_job' class StrictlySerialJob extend Resque::Plugins::LonelyJob @queue = :serial_work def self.perform # only one at a time in this block, no parallelism allowed for this # particular queue end end
Extension 'parallel': Interface for pushung blocks
Ensures that for a given queue, only one worker is working on a job at any given time. Example: require 'resque/plugins/unique_at_runtime' class StrictlySerialJob include Resque::Plugins::UniqueAtRuntime @queue = :serial_work def self.perform # only one at a time in this block, no parallelism allowed for this # particular queue end end
A locking mechanism. Builds queue of concurrent code blocks using Redis.
Allows you to requeue jobs to another queue This is useful in my situations : - A large amount of jobs are queued in the critical queue, blocking the main queue for Several hours. Select jobs based on criteria and requeue them to the low queue
Ruby based Slack bot framework, for AWS Lambda; event queue based. Also provides Block Kit helper.
Ensures that for a given queue, only one worker is working on a job at any given time. Example: require 'resque/plugins/lonely_job' class StrictlySerialJob extend Resque::Plugins::LonelyJob @queue = :serial_work def self.perform # only one at a time in this block, no parallelism allowed for this # particular queue end end
No description provided.
No description provided.
No description provided.
No description provided.
No description provided.
No description provided.