lib/noda/rqueue.rb in noda-0.0.13 vs lib/noda/rqueue.rb in noda-0.0.14

@@ -1,53 +1,76 @@
 # -*- utf8 -*-
 
 module Noda
 require 'monitor'
-# ƒWƒ‡ƒu‚̃Lƒ…�[ŽÀ‘•
-# ƒLƒ…�[‚̓XƒŒƒbƒhƒZ�[ƒt‚É�‘‚¢‚Ä‚¢‚é
+# ジョブ�キュー実装
+# キュー�スレッドセーフ�書���る
+# 
+# キュー�ら値を�り出���キュー��残ら��。
+# ==使用法
+#     require 'noda'
+#     server =Noda::JobServer.new
+#     q = server.input #<= Jobサー�ー����る
+#     q.push Noda::MyTask.new("hogehgoe")
 #
-#
 class RQueue
   include DRb::DRbUndumped 
   attr_reader :name
+  # 
   def initialize( max=nil, name=nil )
     @name = name
     @list = []
     @max = nil
     @max = max if max
     self.extend(MonitorMixin)
     @m_empty = self.new_cond
     @m_full = self.new_cond
   end
+  # キュー末尾�オブジェクトを追加。
+  #
+  # キュー満�時�実行スレッドをWait����。
   def push obj
     self.synchronize{
       @m_full.wait_while{ self.full?  } if @max
       @list.push obj
       @m_empty.broadcast
     }
   end
+  # キュー先頭�らオブジェクトを�り出�．
+  #
+  # キュー空�ら実行スレッドをWait��る．
   def pop
     self.synchronize{
       @m_empty.wait_while{ self.empty?  }
       obj = @list.shift
       @m_full.broadcast if @max
       obj
     }
   end
+  # 実験用メソッド・使���．
   def include?(v) @list.include? v        end
   alias exists? include?
+  # キュー�先頭N個を�り出�．
   def firsts(n=1) (0...n).map{self.pop}   end
+  # キュー�先頭１個を�り出�． pop �別�
   def first()     self.pop                end
+  # キュー�サイズを�得
   def size()      @list.size              end
+  # キュー格��能数
   def max_size()  @max                    end
+  # キュー�値��る�
   def empty?()    @list.empty?            end
+  # キュー満��近����Trueを返�．
   def close_to_full?()    @list.size >= @max-5    end
+  # キュー�満�����
   def full?()
-    # max=nil ‚È‚çLimitless�B‚‚܂薳ŒÀ‘å
+    # max=nil �らLimitless。��り無�大
     @list.size >= @max if @max
   end
+  # キュー�値全�を�り出�．
   def all() self.firsts(self.size) end
-  # ‚P‚©‚ç‚m‚Ü‚Å‚Ì’l‚ðŽæ‚é�B‚OŽn‚Ü‚è‚Å‚È‚¢‚±‚Æ‚É’�ˆÓ
+  # キュー�先頭N番目�値を調�る．�ェック用。
+  # - pos １�らＮ���値を�る。先頭�1 �指定�る．�始�り������注�
   def _at(pos) 
     i = pos - 1 
     return @list.at(i) if (i) < self.size 
   end
 end
\ No newline at end of file