changed waiting list interface

Author: mighe

lib/concurrent/channel/buffered_channel.rb

@@ -36,7 +36,7 @@ def select(probe)
       @mutex.synchronize do
 
         if @buffer.empty?
-          @probe_set.push(probe)
+          @probe_set.put(probe)
           true
         else
           shift_buffer if probe.set_unless_assigned peek_buffer
@@ -83,7 +83,7 @@ def set_probe_or_push_into_buffer(value)
           push_into_buffer(value)
           true
         else
-          @probe_set.first.set_unless_assigned(value)
+          @probe_set.take.set_unless_assigned(value)
         end
       end
     end

lib/concurrent/channel/unbuffered_channel.rb

@@ -12,7 +12,7 @@ def probe_set_size
     end
 
     def push(value)
-      until @probe_set.first.set_unless_assigned(value)
+      until @probe_set.take.set_unless_assigned(value)
       end
     end
 
@@ -23,7 +23,7 @@ def pop
     end
 
     def select(probe)
-      @probe_set.push(probe)
+      @probe_set.put(probe)
     end
 
     def remove_probe(probe)

lib/concurrent/channel/waitable_list.rb

@@ -16,7 +16,7 @@ def empty?
       @mutex.synchronize { @list.empty? }
     end
 
-    def push(value)
+    def put(value)
       @mutex.synchronize do
         @list << value
         @condition.signal
@@ -27,7 +27,7 @@ def delete(value)
       @mutex.synchronize { @list.delete(value) }
     end
 
-    def first
+    def take
       @mutex.synchronize do
         @condition.wait(@mutex) while @list.empty?
         @list.shift