[macruby-changes] [4305] MacRuby/trunk/sample-macruby/Scripts/gcd
source_changes at macosforge.org
source_changes at macosforge.org
Tue Jun 29 17:15:06 PDT 2010
Revision: 4305
http://trac.macosforge.org/projects/ruby/changeset/4305
Author: ernest.prabhakar at 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) }
+ at 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) }
+ at values = job.values
+puts @values # => [1.0E50, 4294967296.0]
+job = Dispatch::Job.new
+ at 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"]
+ at 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)
+ at 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!
+ at 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!
+ at mask = 0
+masker = Dispatch::Source.or { |s| @mask |= s.data }
+masker.suspend!
+masker << 0b0011
+masker << 0b1010
+masker.resume!
+puts "%b" % @mask # => 1011
+masker.cancel!
+ at event = 0
+mask = Dispatch::Source::PROC_EXIT | Dispatch::Source::PROC_SIGNAL
+proc_src = Dispatch::Source.process($$, mask) do |s|
+ at event |= s.data
+end
+
+
+ at 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
+ at count = 0
+sig_usr2 = Signal.list["USR2"]
+signal = Dispatch::Source.signal(sig_usr2) do |s|
+ at 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!
+ at fevent = 0
+ at 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|
+ at fevent |= s.data
+end
+file.close
+puts @fevent & fmask # => Dispatch::Source::Source.VNODE_WRITE
+File.delete(filename)
+puts @fevent == fmask # => true
+file_src.cancel!
+
+ at fevent2 = []
+file = File.open(filename, "w")
+fmask2 = %w(delete write)
+file_src2 = Dispatch::Source.file(file, fmask2) do |s|
+ at 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) }
- at 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) }
- at values = job.values
-puts @values # => [1.0E50, 4294967296.0]
-job = Dispatch::Job.new
- at hash = job.synchronize {}
-puts @hash.class # => Dispatch::Proxy
-
-puts job.values.class # => Dispatch::Proxy
-
- at 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}
-
- at 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!
- at 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!
- at mask = 0
-masker = Dispatch::Source.or { |s| @mask |= s.data }
-masker.suspend!
-masker << 0b0011
-masker << 0b1010
-masker.resume!
-puts "%b" % @mask # => 1011
-masker.cancel!
- at event = 0
-mask = Dispatch::Source::PROC_EXIT | Dispatch::Source::PROC_SIGNAL
-proc_src = Dispatch::Source.process($$, mask) do |s|
- at event |= s.data
-end
-
-
- at 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
- at count = 0
-sig_usr2 = Signal.list["USR2"]
-signal = Dispatch::Source.signal(sig_usr2) do |s|
- at 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!
- at fevent = 0
- at 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|
- at fevent |= s.data
-end
-file.close
-puts @fevent & fmask # => Dispatch::Source::Source.VNODE_WRITE
-File.delete(filename)
-puts @fevent == fmask # => true
-file_src.cancel!
-
- at fevent2 = []
-file = File.open(filename, "w")
-fmask2 = %w(delete write)
-file_src2 = Dispatch::Source.file(file, fmask2) do |s|
- at fevent2 << Dispatch::Source.data2events(s.data)
-end
-puts @fevent2 & fmask2 # => [:write]
-file_src2.cancel!
-
- @result << @file.read(s.data)
-end
-reader.cancel!
-------------- next part --------------
An HTML attachment was scrubbed...
URL: <http://lists.macosforge.org/pipermail/macruby-changes/attachments/20100629/6e7f8b1f/attachment-0001.html>
More information about the macruby-changes
mailing list