Bloking FIFO queue and flow control using Promise.
Memory optimized promise blocking queue with concurrency control
Blocking queue functions
AsyncBlockingQueue
A simple blocking (asynchronous) priority queue (sorted, not FIFO).
Offload tasks to a pool of workers on node.js and in the browser
set blocking stdio and stderr ensuring that terminal output does not truncate
Tiny queue data structure
fast, tiny `queueMicrotask` shim for modern engines
qjobs is a simple and stupid queue job manager for nodejs
No description provided.
A shim for the setImmediate efficient script yielding API
Promise queue with concurrency control
WebDriver Proxy for testing rich clients. It block certain calls until Angular is done updating the page under test.
The smallest and simplest JavaScript priority queue
A simple tool to keep requests to be executed in order.
High Performance Layer 1 / Layer 2 Caching with Keyv Storage
queue-lit is a tiny queue data structure in case you `Array#push()` or `Array#shift()` on large arrays very often
Next tick shim that prefers process.nextTick over queueMicrotask for compat
Simple JS queue with auto run for node and browsers
In memory queue system prioritizing tasks
Promise-based queue
LRU Queue
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.
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.
No description provided.
No description provided.