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.



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) 


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

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

#kill ⇒ Object

Stop the task.



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

def kill
  @thread.raise
end