Module: PgExport::Concurrency

Included in:
PgExport
Defined in:
lib/pg_export/concurrency.rb

Defined Under Namespace

Classes: ThreadsArray

Class Method Summary collapse

Instance Method Summary collapse

Class Method Details

.included ⇒ Object 



11
12
13
 
# File 'lib/pg_export/concurrency.rb', line 11

def self.included(*)
  Thread.abort_on_exception = true
end

Instance Method Details

#concurrently {|t| ... } ⇒ Object

Yields:

  • (t) 


15
16
17
18
19
 
# File 'lib/pg_export/concurrency.rb', line 15

def concurrently
  t = ThreadsArray.new
  yield t
  t.each(&:join)
end