Revision: 4305 http://trac.macosforge.org/projects/ruby/changeset/4305 Author: ernest.prabhakar@gmail.com Date: 2010-06-29 17:15:05 -0700 (Tue, 29 Jun 2010) Log Message: ----------- Moved rdoc back into _methods Modified Paths: -------------- MacRuby/trunk/sample-macruby/Scripts/gcd/dispatch_methods.rb Removed Paths: ------------- MacRuby/trunk/sample-macruby/Scripts/gcd/dispatch_rdoc.rb Modified: MacRuby/trunk/sample-macruby/Scripts/gcd/dispatch_methods.rb =================================================================== --- MacRuby/trunk/sample-macruby/Scripts/gcd/dispatch_methods.rb 2010-06-30 00:14:04 UTC (rev 4304) +++ MacRuby/trunk/sample-macruby/Scripts/gcd/dispatch_methods.rb 2010-06-30 00:15:05 UTC (rev 4305) @@ -1,46 +1,150 @@ -#!/usr/local/bin/macruby +#!/usr/bin/env macruby + require 'dispatch' +job = Dispatch::Job.new { Math.sqrt(10**100) } +@result = job.value +puts @result.to_int.to_s.size # => 51 -puts "\n Use Dispatch.async to do stuff on another thread or core) " -Dispatch.async { p "Did this elsewhere" } -sleep 0.1 # => "Did this elsewhere" +job.value {|v| p v.to_int.to_s.size } # => 51 (eventually) +job.join +puts "All Done" -puts "\n Use Dispatch.group to track when async stuff completes" -g = Dispatch.group { p "Do this" } -Dispatch.group(g) { p "and that" } -g.wait # => "Do this" "and that" -p "Done" +job.join { puts "All Done" } +job.add { Math.sqrt(2**64) } +@values = job.values +puts @values # => [1.0E50, 4294967296.0] +job = Dispatch::Job.new +@hash = job.synchronize {} +puts @hash.class # => Dispatch::Proxy -puts "\n Use Dispatch.fork to capture return values of async stuff" -f = Dispatch.fork { 2+2 } -p f.value # => 4 -puts " - pass a block to return the value asynchronously" -f.value { |v| p "Returns #{v}" } -sleep 0.1 # => "Returns 4" +puts job.values.class # => Dispatch::Proxy -puts "\n Use Dispatch::Queue.for to create a private serial queue" -puts " - synchronizes access to shared data structures" -a = Array.new -q = Dispatch::Queue.for(a) -puts " - has a (mostly) unique name:" -p q # => Dispatch.enumerable.array.0x2000a6920.1266002369.9854 -q.async { a << "change me" } -puts " - uses sync to block and flush queue" -q.sync { p a } # => ["change me"] +@hash[:foo] = :bar +puts @hash.to_s # => "{:foo=>:bar}" -puts "\n Use with a group for more complex dependencies, " -q.async(g) { a << "more change" } -Dispatch.group(g) do - tmp = "complex calculation" - q.async(g) { a << tmp } + +[64, 100].each do |n| + job << { @hash[n] = Math.sqrt(10**n) } end -puts " - uses notify to execute block when done" -g.notify(q) { p a } -q.sync {} # => ["change me", "more change", "complex calculation"] +puts @hash.inspect # => {64 => 1.0E32, 100 => 1.0E50} -puts "\n Use DispatchDispatch::Proxy.new to serialize object using an Actor" -b = DispatchDispatch::Proxy.new(Array) -b << "safely change me" -p b.size # => 1 (synchronous return) -b.size {|n| p "Size=#{n}"} -sleep 0.1 # => "Size=1" (asynchronous return) +@hash.inspect { |s| p s } # => {64 => 1.0E32, 100 => 1.0E50} +delegate = @hash.__value__ +puts delegate.class # => Hash + +n = 42 +job = Dispatch::Job.new { p n } +job.join # => 42 + +n = 0 +job = Dispatch::Job.new { n = 42 } +job.join +p n # => 0 +n = 0 +job = Dispatch::Job.new { n += 42 } +job.join +p n # => 0 +5.p_times { |i| puts 10**i } # => 1 100 1000 10 10000 + +5.p_times(3) { |i| puts 10**i } # =>1000 10000 1 10 100 +%w(Mon Tue Wed Thu Fri).p_each { |day| puts day} # => Mon Wed Thu Tue Fri +%w(Mon Tue Wed Thu Fri).p_each(3) { |day| puts day} # => Thu Fri Mon Tue Wed +%w(Mon Tue Wed Thu Fri).p_each { |day, i | puts "#{i}:#{day}"} # => 0:Mon 2:Wed 3:Thu 1:Tue 4:Fri +%w(Mon Tue Wed Thu Fri).p_each(3) { |day, i | puts "#{i}:#{day}"} # => 3:Thu 4:Fri 0:Mon 1:Tue 2:Wed +(0..4).p_map { |i| 10**i } # => [1, 1000, 10, 100, 10000] +(0..4).p_map(3) { |i| 10**i } # => [1000, 10000, 1, 10, 100] +(0..4).p_mapreduce(0) { |i| 10**i } # => 11111 +This uses a parallel +inject+ (formerly known as +reduce+) to return a single value by combining the result of +map+. Unlike +inject+, you must specify an explicit initial value as the first parameter. The default accumulator is ":+", but you can specify a different symbol to +send+: +(0..4).p_mapreduce([], :concat) { |i| [10**i] } # => [1, 1000, 10, 100, 10000] + +(0..4).p_mapreduce([], :concat, 3) { |i| [10**i] } # => [1000, 10000, 1, 10, 100] +(0..4).p_findall { |i| i.odd?} # => {3, 1} +(0..4).p_findall(3) { |i| i.odd?} # => {3, 1} + +(0..4).p_findall { |i| i == 5 } # => nil +(0..4).p_findall { |i| i.odd?} # => 1 +(0..4).p_findall(3) { |i| i.odd?} # => 3 + +timer = Source.periodic(0.9) { |src| puts src.data } +sleep 2 # => 1 1 ... + +timer.suspend! +sleep 2 +timer.resume! +sleep 2 # => 2 1 ... +timer.cancel! +@sum = 0 +adder = Dispatch::Source.add { |s| @sum += s.data; } +adder << 1 # => "add 1 -> 1" +adder.suspend! +adder << 3 +adder << 5 +adder.resume! # => "add 8 -> 9" +adder.cancel! +@mask = 0 +masker = Dispatch::Source.or { |s| @mask |= s.data } +masker.suspend! +masker << 0b0011 +masker << 0b1010 +masker.resume! +puts "%b" % @mask # => 1011 +masker.cancel! +@event = 0 +mask = Dispatch::Source::PROC_EXIT | Dispatch::Source::PROC_SIGNAL +proc_src = Dispatch::Source.process($$, mask) do |s| +@event |= s.data +end + + +@events = [] +mask2 = [:exit, :fork, :exec, signal] +proc_src2 = Dispatch::Source.process($$, mask2) do |s| + |s| @events << Dispatch::Source.data2events(s.data) +end +sig_usr1 = Signal.list["USR1"] +Signal.trap(sig_usr1, "IGNORE") +Process.kill(sig_usr1, $$) +Signal.trap(sig_usr1, "DEFAULT") +result = "%b" % (@event & mask) # => 1000000000000000000000000000 # Dispatch::Source::PROC_SIGNAL +proc_src.cancel! +result2 = (@events & mask2) # => [:signal] +proc_src2.cancel! +puts result == Dispatch::Source#event2num(result2[0]) # => true +put result2[0] == Dispatch::Source#num2event(result) # => true +@count = 0 +sig_usr2 = Signal.list["USR2"] +signal = Dispatch::Source.signal(sig_usr2) do |s| +@count += s.data +end +signal.suspend! +Signal.trap(sig_usr2, "IGNORE") +3.times { Process.kill(sig_usr2, $$) } +Signal.trap(sig_usr2, "DEFAULT") +signal.resume! +puts @count # => 3 +signal.cancel! +@fevent = 0 +@msg = "#{$$}-#{Time.now.to_s.gsub(' ','_')}" +file = File.open(filename, "w") +fmask = Dispatch::Source::VNODE_DELETE | Dispatch::Source::Source.VNODE_WRITE +file_src = Dispatch::Source.file(file.fileno, fmask) do |s| +@fevent |= s.data +end +file.close +puts @fevent & fmask # => Dispatch::Source::Source.VNODE_WRITE +File.delete(filename) +puts @fevent == fmask # => true +file_src.cancel! + +@fevent2 = [] +file = File.open(filename, "w") +fmask2 = %w(delete write) +file_src2 = Dispatch::Source.file(file, fmask2) do |s| +@fevent2 << Dispatch::Source.data2events(s.data) +end +puts @fevent2 & fmask2 # => [:write] +file_src2.cancel! + + @result << @file.read(s.data) +end +reader.cancel! Deleted: MacRuby/trunk/sample-macruby/Scripts/gcd/dispatch_rdoc.rb =================================================================== --- MacRuby/trunk/sample-macruby/Scripts/gcd/dispatch_rdoc.rb 2010-06-30 00:14:04 UTC (rev 4304) +++ MacRuby/trunk/sample-macruby/Scripts/gcd/dispatch_rdoc.rb 2010-06-30 00:15:05 UTC (rev 4305) @@ -1,150 +0,0 @@ -#!/usr/bin/env macruby - -require 'dispatch' -job = Dispatch::Job.new { Math.sqrt(10**100) } -@result = job.value -puts @result.to_int.to_s.size # => 51 - -job.value {|v| p v.to_int.to_s.size } # => 51 (eventually) -job.join -puts "All Done" - -job.join { puts "All Done" } -job.add { Math.sqrt(2**64) } -@values = job.values -puts @values # => [1.0E50, 4294967296.0] -job = Dispatch::Job.new -@hash = job.synchronize {} -puts @hash.class # => Dispatch::Proxy - -puts job.values.class # => Dispatch::Proxy - -@hash[:foo] = :bar -puts @hash.to_s # => "{:foo=>:bar}" - - -[64, 100].each do |n| -job << { @hash[n] = Math.sqrt(10**n) } -end -puts @hash.inspect # => {64 => 1.0E32, 100 => 1.0E50} - -@hash.inspect { |s| p s } # => {64 => 1.0E32, 100 => 1.0E50} -delegate = @hash.__value__ -puts delegate.class # => Hash - -n = 42 -job = Dispatch::Job.new { p n } -job.join # => 42 - -n = 0 -job = Dispatch::Job.new { n = 42 } -job.join -p n # => 0 -n = 0 -job = Dispatch::Job.new { n += 42 } -job.join -p n # => 0 -5.p_times { |i| puts 10**i } # => 1 100 1000 10 10000 - -5.p_times(3) { |i| puts 10**i } # =>1000 10000 1 10 100 -%w(Mon Tue Wed Thu Fri).p_each { |day| puts day} # => Mon Wed Thu Tue Fri -%w(Mon Tue Wed Thu Fri).p_each(3) { |day| puts day} # => Thu Fri Mon Tue Wed -%w(Mon Tue Wed Thu Fri).p_each { |day, i | puts "#{i}:#{day}"} # => 0:Mon 2:Wed 3:Thu 1:Tue 4:Fri -%w(Mon Tue Wed Thu Fri).p_each(3) { |day, i | puts "#{i}:#{day}"} # => 3:Thu 4:Fri 0:Mon 1:Tue 2:Wed -(0..4).p_map { |i| 10**i } # => [1, 1000, 10, 100, 10000] -(0..4).p_map(3) { |i| 10**i } # => [1000, 10000, 1, 10, 100] -(0..4).p_mapreduce(0) { |i| 10**i } # => 11111 -This uses a parallel +inject+ (formerly known as +reduce+) to return a single value by combining the result of +map+. Unlike +inject+, you must specify an explicit initial value as the first parameter. The default accumulator is ":+", but you can specify a different symbol to +send+: -(0..4).p_mapreduce([], :concat) { |i| [10**i] } # => [1, 1000, 10, 100, 10000] - -(0..4).p_mapreduce([], :concat, 3) { |i| [10**i] } # => [1000, 10000, 1, 10, 100] -(0..4).p_findall { |i| i.odd?} # => {3, 1} -(0..4).p_findall(3) { |i| i.odd?} # => {3, 1} - -(0..4).p_findall { |i| i == 5 } # => nil -(0..4).p_findall { |i| i.odd?} # => 1 -(0..4).p_findall(3) { |i| i.odd?} # => 3 - -timer = Source.periodic(0.9) { |src| puts src.data } -sleep 2 # => 1 1 ... - -timer.suspend! -sleep 2 -timer.resume! -sleep 2 # => 2 1 ... -timer.cancel! -@sum = 0 -adder = Dispatch::Source.add { |s| @sum += s.data; } -adder << 1 # => "add 1 -> 1" -adder.suspend! -adder << 3 -adder << 5 -adder.resume! # => "add 8 -> 9" -adder.cancel! -@mask = 0 -masker = Dispatch::Source.or { |s| @mask |= s.data } -masker.suspend! -masker << 0b0011 -masker << 0b1010 -masker.resume! -puts "%b" % @mask # => 1011 -masker.cancel! -@event = 0 -mask = Dispatch::Source::PROC_EXIT | Dispatch::Source::PROC_SIGNAL -proc_src = Dispatch::Source.process($$, mask) do |s| -@event |= s.data -end - - -@events = [] -mask2 = [:exit, :fork, :exec, signal] -proc_src2 = Dispatch::Source.process($$, mask2) do |s| - |s| @events << Dispatch::Source.data2events(s.data) -end -sig_usr1 = Signal.list["USR1"] -Signal.trap(sig_usr1, "IGNORE") -Process.kill(sig_usr1, $$) -Signal.trap(sig_usr1, "DEFAULT") -result = "%b" % (@event & mask) # => 1000000000000000000000000000 # Dispatch::Source::PROC_SIGNAL -proc_src.cancel! -result2 = (@events & mask2) # => [:signal] -proc_src2.cancel! -puts result == Dispatch::Source#event2num(result2[0]) # => true -put result2[0] == Dispatch::Source#num2event(result) # => true -@count = 0 -sig_usr2 = Signal.list["USR2"] -signal = Dispatch::Source.signal(sig_usr2) do |s| -@count += s.data -end -signal.suspend! -Signal.trap(sig_usr2, "IGNORE") -3.times { Process.kill(sig_usr2, $$) } -Signal.trap(sig_usr2, "DEFAULT") -signal.resume! -puts @count # => 3 -signal.cancel! -@fevent = 0 -@msg = "#{$$}-#{Time.now.to_s.gsub(' ','_')}" -file = File.open(filename, "w") -fmask = Dispatch::Source::VNODE_DELETE | Dispatch::Source::Source.VNODE_WRITE -file_src = Dispatch::Source.file(file.fileno, fmask) do |s| -@fevent |= s.data -end -file.close -puts @fevent & fmask # => Dispatch::Source::Source.VNODE_WRITE -File.delete(filename) -puts @fevent == fmask # => true -file_src.cancel! - -@fevent2 = [] -file = File.open(filename, "w") -fmask2 = %w(delete write) -file_src2 = Dispatch::Source.file(file, fmask2) do |s| -@fevent2 << Dispatch::Source.data2events(s.data) -end -puts @fevent2 & fmask2 # => [:write] -file_src2.cancel! - - @result << @file.read(s.data) -end -reader.cancel!