Class: Open4::ThreadEnsemble
- Inherits:
-
Object
- Object
- Open4::ThreadEnsemble
- Defined in:
- lib/open4.rb
Instance Attribute Summary collapse
-
#threads ⇒ Object
readonly
–{{{.
Instance Method Summary collapse
- #add_thread(*a, &b) ⇒ Object
- #all_done ⇒ Object
-
#initialize(cid) ⇒ ThreadEnsemble
constructor
A new instance of ThreadEnsemble.
-
#killall ⇒ Object
take down process more nicely.
- #run ⇒ Object
Constructor Details
#initialize(cid) ⇒ ThreadEnsemble
Returns a new instance of ThreadEnsemble.
107 108 109 110 |
# File 'lib/open4.rb', line 107 def initialize cid @cid, @threads, @argv, @done, @running = cid, [], [], Queue.new, false @killed = false end |
Instance Attribute Details
#threads ⇒ Object (readonly)
–{{{
105 106 107 |
# File 'lib/open4.rb', line 105 def threads @threads end |
Instance Method Details
#add_thread(*a, &b) ⇒ Object
112 113 114 |
# File 'lib/open4.rb', line 112 def add_thread *a, &b @running ? raise : (@argv << [a, b]) end |
#all_done ⇒ Object
153 154 155 |
# File 'lib/open4.rb', line 153 def all_done @threads.size.times{ @done.pop } end |
#killall ⇒ Object
take down process more nicely
119 120 121 122 123 124 125 126 127 |
# File 'lib/open4.rb', line 119 def killall c = Thread.critical return nil if @killed Thread.critical = true (@threads - [Thread.current]).each{|t| t.kill rescue nil} @killed = true ensure Thread.critical = c end |
#run ⇒ Object
129 130 131 132 133 134 135 136 137 138 139 140 141 142 143 144 145 146 147 148 149 150 151 |
# File 'lib/open4.rb', line 129 def run @running = true begin @argv.each do |a, b| @threads << Thread.new(*a) do |*a| begin b[*a] ensure killall rescue nil if $! @done.push Thread.current end end end rescue killall raise ensure all_done end @threads.map{|t| t.value} end |