Class: ConcurrentPipeline::Processors::ActorProcessor::ActorPool::Pool

Inherits:
Object
  • Object
show all
Extended by:
PipeActor
Defined in:
lib/concurrent_pipeline/processors/actor_processor.rb

Instance Attribute Summary collapse

Instance Method Summary collapse

Methods included from PipeActor

default_block, extended, on_blocks, spawn

Constructor Details

#initialize(concurrency = 10000) ⇒ Pool

Returns a new instance of Pool.



124
125
126
127
128
 
# File 'lib/concurrent_pipeline/processors/actor_processor.rb', line 124

def initialize(concurrency= 10000)
  @concurrency = concurrency
  @queue = []
  @processing_count = 0
end

Instance Attribute Details

#concurrency ⇒ Object (readonly)

Returns the value of attribute concurrency.



123
124
125
 
# File 'lib/concurrent_pipeline/processors/actor_processor.rb', line 123

def concurrency
  @concurrency
end

#processing_count ⇒ Object (readonly)

Returns the value of attribute processing_count.



123
124
125
 
# File 'lib/concurrent_pipeline/processors/actor_processor.rb', line 123

def processing_count
  @processing_count
end

#queue ⇒ Object (readonly)

Returns the value of attribute queue.



123
124
125
 
# File 'lib/concurrent_pipeline/processors/actor_processor.rb', line 123

def queue
  @queue
end