Class: Parallel::Worker
- Inherits:
-
Object
- Object
- Parallel::Worker
- Defined in:
- lib/parallel.rb
Instance Attribute Summary collapse
-
#pid ⇒ Object
readonly
Returns the value of attribute pid.
-
#read ⇒ Object
readonly
Returns the value of attribute read.
-
#thread ⇒ Object
Returns the value of attribute thread.
-
#write ⇒ Object
readonly
Returns the value of attribute write.
Instance Method Summary collapse
-
#close_pipes ⇒ Object
might be passed to started_processes and simultaneously closed by another thread when running in isolation mode, so we have to check if it is closed before closing.
-
#initialize(read, write, pid) ⇒ Worker
constructor
A new instance of Worker.
- #stop ⇒ Object
- #work(data) ⇒ Object
Constructor Details
#initialize(read, write, pid) ⇒ Worker
Returns a new instance of Worker.
34 35 36 |
# File 'lib/parallel.rb', line 34 def initialize(read, write, pid) @read, @write, @pid = read, write, pid end |
Instance Attribute Details
#pid ⇒ Object (readonly)
Returns the value of attribute pid.
32 33 34 |
# File 'lib/parallel.rb', line 32 def pid @pid end |
#read ⇒ Object (readonly)
Returns the value of attribute read.
32 33 34 |
# File 'lib/parallel.rb', line 32 def read @read end |
#thread ⇒ Object
Returns the value of attribute thread.
33 34 35 |
# File 'lib/parallel.rb', line 33 def thread @thread end |
#write ⇒ Object (readonly)
Returns the value of attribute write.
32 33 34 |
# File 'lib/parallel.rb', line 32 def write @write end |
Instance Method Details
#close_pipes ⇒ Object
might be passed to started_processes and simultaneously closed by another thread when running in isolation mode, so we have to check if it is closed before closing
45 46 47 48 |
# File 'lib/parallel.rb', line 45 def close_pipes read.close unless read.closed? write.close unless write.closed? end |
#stop ⇒ Object
38 39 40 41 |
# File 'lib/parallel.rb', line 38 def stop close_pipes wait # if it goes zombie, rather wait here to be able to debug end |
#work(data) ⇒ Object
50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 |
# File 'lib/parallel.rb', line 50 def work(data) begin Marshal.dump(data, write) rescue Errno::EPIPE raise DeadWorker end result = begin Marshal.load(read) rescue EOFError raise DeadWorker end raise result.exception if ExceptionWrapper === result result end |