method

push

v1_9_2_180 - Show latest stable - 0 notes - Class: SizedQueue

1_8_6_287 (0)
1_8_7_72 (0)
1_8_7_330 (0)
1_9_1_378 (-3)
1_9_2_180 (0)
1_9_3_125 (0)
1_9_3_392 (0)
2_1_10 (1)
2_2_9 (38)
2_4_6 (0)
2_5_5 (0)
2_6_3 (0)
What's this?

push(obj) public

Pushes obj to the queue. If there is no space left in the queue, waits until space becomes available.

# File lib/thread.rb, line 292
  def push(obj)
    @mutex.synchronize{
      while true
        break if @que.length < @max
        @queue_wait.push Thread.current
        @mutex.sleep
      end

      @que.push obj
      begin
        t = @waiting.shift
        t.wakeup if t
      rescue ThreadError
        retry
      end
    }
  end

push

Related methods

Flowdock - Team Inbox With Chat for Software Developers