Class: Thread::Pipe::Task

Inherits:
Object
  • Object
show all
Defined in:
lib/thread/pipe.rb

Overview

A task encapsulates a part of the pipe.

Instance Attribute Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(func, input = Queue.new, output = Queue.new) ⇒ Task

Create a Task which will call the passed function and get input from the optional parameter and put output in the optional parameter.

[View source]

23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
 
# File 'lib/thread/pipe.rb', line 23

def initialize(func, input = Queue.new, output = Queue.new)
	@input    = input
	@output   = output
	@handling = false

	@thread = Thread.new {
		while true
			value = @input.deq

			@handling = true
			begin
				value = func.call(value)
				@output.enq value
			rescue Exception; end
			@handling = false
		end
	}
end

Instance Attribute Details

#input ⇒ Object

Returns the value of attribute input.


19
20
21
 
# File 'lib/thread/pipe.rb', line 19

def input
  @input
end

#output ⇒ Object

Returns the value of attribute output.


19
20
21
 
# File 'lib/thread/pipe.rb', line 19

def output
  @output
end

Instance Method Details

#empty? ⇒ Boolean

Check if the task has nothing to do.

Returns:

  • (Boolean)
[View source]

43
44
45
 
# File 'lib/thread/pipe.rb', line 43

def empty?
	!@handling && @input.empty? && @output.empty?
end

#kill ⇒ Object

Stop the task.

[View source]

48
49
50
 
# File 'lib/thread/pipe.rb', line 48

def kill
	@thread.raise
end