Class: Brute::Queue::ParallelQueue

Inherits:

BaseQueue

• Object
• BaseQueue
• Brute::Queue::ParallelQueue

Defined in:

lib/brute/queue/parallel_queue.rb

Overview

A queue that processes steps concurrently up to a limit. Workers match concurrency slots.

Instance Attribute Summary

Attributes inherited from BaseQueue

#steps

Instance Method Summary

• #initialize(concurrency: 4, parent: Async::Task.current) ⇒ ParallelQueue constructor

  A new instance of ParallelQueue.

Methods inherited from BaseQueue

#<<, #cancel, #drain, #first, #last, #start

Constructor Details

#initialize(concurrency: 4, parent: Async::Task.current) ⇒ ParallelQueue

Returns a new instance of ParallelQueue.

# File 'lib/brute/queue/parallel_queue.rb', line 11

def initialize(concurrency: 4, parent: Async::Task.current)
  super(concurrency: concurrency, worker_count: concurrency, parent: parent)
end