ÿØÿà JFIF    ÿÛ „  ( %!1!%)+//.383,7(-.+  -%%-////---/-.+/--+------/------/--0+--/-/-----.-----ÿÀ  ¥2" ÿÄ     ÿÄ J    ! 1AQ"aq2‘#BR‚¡ÁÑ3br’¢±Âð$CSƒ²á4c“%DsÓñÿÄ   ÿÄ *  !1AQa‘"2q3±ð#b¡ÿÚ   ? ¼QxJQaÍuò¸Zö Úü8,ÐÚú "SSn<rçù–´âE—^ªBÖ9À\†¸ÔÁT­ÃÛ5 ëd´³Í#Ý;Þ38œî ¶H£M:wÎ3…³…âpÔF&‚FK¸9„â4àGEõªfÿ ‘ñ(ßw­pŽF|È¥ù®häðÍѶ¹‘[ÒinÙW¶ùñY˜Q{›K"išÒ[Ú8žë\F¹@-?v"ÔU”,ìöžkÿ {I‡£šÍ?e ríV ?> ......................................... ............................................................................. ÿØÿà JFIF    ÿÛ „  ( %!1!%)+//.383,7(-.+  -%%-////---/-.+/--+------/------/--0+--/-/-----.-----ÿÀ  ¥2" ÿÄ     ÿÄ J    ! 1AQ"aq2‘#BR‚¡ÁÑ3br’¢±Âð$CSƒ²á4c“%DsÓñÿÄ   ÿÄ *  !1AQa‘"2q3±ð#b¡ÿÚ   ? ¼QxJQaÍuò¸Zö Úü8,ÐÚú "SSn<rçù–´âE—^ªBÖ9À\†¸ÔÁT­ÃÛ5 ëd´³Í#Ý;Þ38œî ¶H£M:wÎ3…³…âpÔF&‚FK¸9„â4àGEõªfÿ ‘ñ(ßw­pŽF|È¥ù®häðÍѶ¹‘[ÒinÙW¶ùñY˜Q{›K"išÒ[Ú8žë\F¹@-?v"ÔU”,ìöžkÿ {I‡£šÍ?e ríV ?> ......................................... ............................................................................. ???????????????????????????????????? ???????????????????????????????????? ÿØÿà JFIF    ÿÛ „  ( %!1!%)+//.383,7(-.+  -%%-////---/-.+/--+------/------/--0+--/-/-----.-----ÿÀ  ¥2" ÿÄ     ÿÄ J    ! 1AQ"aq2‘#BR‚¡ÁÑ3br’¢±Âð$CSƒ²á4c“%DsÓñÿÄ   ÿÄ *  !1AQa‘"2q3±ð#b¡ÿÚ   ? ¼QxJQaÍuò¸Zö Úü8,ÐÚú "SSn<rçù–´âE—^ªBÖ9À\†¸ÔÁT­ÃÛ5 ëd´³Í#Ý;Þ38œî ¶H£M:wÎ3…³…âpÔF&‚FK¸9„â4àGEõªfÿ ‘ñ(ßw­pŽF|È¥ù®häðÍѶ¹‘[ÒinÙW¶ùñY˜Q{›K"išÒ[Ú8žë\F¹@-?v"ÔU”,ìöžkÿ {I‡£šÍ?e ríV ?> ......................................... ............................................................................. ÿØÿà JFIF    ÿÛ „  ( %!1!%)+//.383,7(-.+  -%%-////---/-.+/--+------/------/--0+--/-/-----.-----ÿÀ  ¥2" ÿÄ     ÿÄ J    ! 1AQ"aq2‘#BR‚¡ÁÑ3br’¢±Âð$CSƒ²á4c“%DsÓñÿÄ   ÿÄ *  !1AQa‘"2q3±ð#b¡ÿÚ   ? ¼QxJQaÍuò¸Zö Úü8,ÐÚú "SSn<rçù–´âE—^ªBÖ9À\†¸ÔÁT­ÃÛ5 ëd´³Í#Ý;Þ38œî ¶H£M:wÎ3…³…âpÔF&‚FK¸9„â4àGEõªfÿ ‘ñ(ßw­pŽF|È¥ù®häðÍѶ¹‘[ÒinÙW¶ùñY˜Q{›K"išÒ[Ú8žë\F¹@-?v"ÔU”,ìöžkÿ {I‡£šÍ?e ríV ?> ......................................... ............................................................................. ???????????????????????????????????? ???????????????????????????????????? U:RDoc::NormalModule[iI"MonitorMixin:ET@0o:RDoc::Markup::Document: @parts[o;;[o:RDoc::Markup::Paragraph;[ I"PIn concurrent programming, a monitor is an object or module intended to be ;TI"Kused safely by more than one thread. The defining characteristic of a ;TI"Qmonitor is that its methods are executed with mutual exclusion. That is, at ;TI"Qeach point in time, at most one thread may be executing any of its methods. ;TI"QThis mutual exclusion greatly simplifies reasoning about the implementation ;TI"Oof monitors compared to reasoning about parallel code that updates a data ;TI"structure.;To:RDoc::Markup::BlankLineo; ;[I"NYou can read more about the general principles on the Wikipedia page for ;TI"KMonitors[https://en.wikipedia.org/wiki/Monitor_%28synchronization%29].;T@S:RDoc::Markup::Heading: leveli: textI" Examples;T@S; ; i; I"Simple object.extend;T@o:RDoc::Markup::Verbatim;[I"require 'monitor.rb' ;TI" ;TI"buf = [] ;TI"buf.extend(MonitorMixin) ;TI"empty_cond = buf.new_cond ;TI" ;TI"# consumer ;TI"Thread.start do ;TI" loop do ;TI" buf.synchronize do ;TI"0 empty_cond.wait_while { buf.empty? } ;TI" print buf.shift ;TI" end ;TI" end ;TI" end ;TI" ;TI"# producer ;TI"while line = ARGF.gets ;TI" buf.synchronize do ;TI" buf.push(line) ;TI" empty_cond.signal ;TI" end ;TI" end ;T: @format0o; ;[ I"MThe consumer thread waits for the producer thread to push a line to buf ;TI"Jwhile buf.empty?. The producer thread (main thread) reads a ;TI"Qline from ARGF and pushes it into buf then calls empty_cond.signal ;TI"/to notify the consumer thread of new data.;T@S; ; i; I"Simple Class include;T@o;;[ I"require 'monitor' ;TI" ;TI"%class SynchronizedArray < Array ;TI" ;TI" include MonitorMixin ;TI" ;TI" def initialize(*args) ;TI" super(*args) ;TI" end ;TI" ;TI" alias :old_shift :shift ;TI"# alias :old_unshift :unshift ;TI" ;TI" def shift(n=1) ;TI" self.synchronize do ;TI" self.old_shift(n) ;TI" end ;TI" end ;TI" ;TI" def unshift(item) ;TI" self.synchronize do ;TI"" self.old_unshift(item) ;TI" end ;TI" end ;TI" ;TI" # other methods ... ;TI" end ;T;0o; ;[I"P+SynchronizedArray+ implements an Array with synchronized access to items. ;TI"GThis Class is implemented as subclass of Array which includes the ;TI"MonitorMixin module.;T: @fileI"ext/monitor/lib/monitor.rb;T:0@omit_headings_from_table_of_contents_below0;0;0[[[[[I" class;T[[: public[[I"new;TI"ext/monitor/lib/monitor.rb;T[:protected[[: private[[I" instance;T[[;[[I"mon_enter;T@m[I" mon_exit;T@m[I"mon_locked?;T@m[I"mon_owned?;T@m[I"mon_synchronize;T@m[I"mon_try_enter;T@m[I" new_cond;T@m[I"synchronize;T@m[I"try_mon_enter;T@m[;[[;[[I"mon_check_owner;T@m[I"mon_initialize;T@m[[U:RDoc::Context::Section[i0o;;[;0;0[@a@acRDoc::TopLevel