Object
# File lib/parallel.rb, line 36 def initialize(read, write, pid) @read, @write, @pid = read, write, pid end
# File lib/parallel.rb, line 40 def close_pipes read.close write.close end
# File lib/parallel.rb, line 45 def wait Process.wait(pid) rescue Interrupt # process died end
# File lib/parallel.rb, line 51 def work(data) begin Marshal.dump(data, write) rescue Errno::EPIPE raise DeadWorker end begin Marshal.load(read) rescue EOFError raise DeadWorker end end
[Validate]
Generated with the Darkfish Rdoc Generator 2.