Contents

#!/usr/bin/env ruby

# load required libraries

# modify include path
$: << File.join(File.dirname(__FILE__),'lib')

require 'thread_pool'
require 'calculations'
include Calculations

if ARGV.count!=1
	puts "use: #{$0} threads" 
	exit
end

@pool=ThreadPool.new(ARGV[0].to_i)

# process
  
times_to_calculate=1000

times_to_calculate.times do

  @pool.process {do_dummy_calculations}

end


puts "wait"
@pool.join
puts "final"

Version data entries

8 entries across 8 versions & 1 rubygems

Version	Path
scbi_mapreduce-0.0.45	skeleton/dummy_calcs/threads_implementation.rb
scbi_mapreduce-0.0.40	skeleton/dummy_calcs/threads_implementation.rb
scbi_mapreduce-0.0.38	skeleton/dummy_calcs/threads_implementation.rb
scbi_mapreduce-0.0.37	skeleton/dummy_calcs/threads_implementation.rb
scbi_mapreduce-0.0.36	skeleton/dummy_calcs/threads_implementation.rb
scbi_mapreduce-0.0.35	skeleton/dummy_calcs/threads_implementation.rb
scbi_mapreduce-0.0.31	skeleton/dummy_calcs/threads_implementation.rb
scbi_mapreduce-0.0.29	skeleton/dummy_calcs/threads_implementation.rb