Class: ThrottleQueue::FG

Inherits:
Object
  • Object
show all
Defined in:
lib/throttle-queue/single-process.rb

Overview

:nodoc: all

Instance Method Summary collapse

Constructor Details

#initialize(block, h) ⇒ FG

Returns a new instance of FG.



144
145
146
147
148
149
150
151
 
# File 'lib/throttle-queue/single-process.rb', line 144

def initialize(block, h)
	@block = block
	@thread = Thread.new {
		Thread.stop unless @args
		@block.call *@args
	}
	@h = h
end

Instance Method Details

#arity ⇒ Object 



152
153
154
 
# File 'lib/throttle-queue/single-process.rb', line 152

def arity
	@block.arity
end

#call(*args) ⇒ Object 



155
156
157
158
 
# File 'lib/throttle-queue/single-process.rb', line 155

def call(*args)
	@args = args
	@thread.run
end

#join ⇒ Object 



159
160
161
 
# File 'lib/throttle-queue/single-process.rb', line 159

def join
	@thread.join
end