Contents

require "spec_helper"
require "bunny/concurrent/condition"

describe Bunny::Concurrent::Condition do
  describe "#wait" do
    it "blocks current thread until notified" do
      condition = described_class.new
      xs        = []

      t = Thread.new do
        xs << :notified

        sleep 0.25
        condition.notify
      end
      t.abort_on_exception = true

      condition.wait
      xs.should == [:notified]
    end
  end

  describe "#notify" do
    it "notifies a single thread waiting on the latch" do
      condition = described_class.new
      xs        = []

      t1 = Thread.new do
        condition.wait
        xs << :notified1
      end
      t1.abort_on_exception = true

      t2 = Thread.new do
        condition.wait
        xs << :notified2
      end
      t2.abort_on_exception = true

      sleep 0.25
      condition.notify
      sleep 0.5
      xs.should satisfy { |ys| ys.size == 1 && (ys.include?(:notified1) || ys.include?(:notified2)) }
    end
  end

  describe "#notify_all" do
    let(:n) { 20 }

    it "notifies all the threads waiting on the latch" do
      condition = described_class.new
      @xs        = []

      n.times do |i|
        t = Thread.new do
          condition.wait
          @xs << "notified#{i + 1}".to_sym
        end
        t.abort_on_exception = true
      end

      sleep 0.5
      condition.notify_all
      sleep 0.5

      n.times do |i|
        item = "notified#{i + 1}".to_sym

        @xs.should include(item)
      end
    end
  end
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
bunny-0.9.0.pre10	spec/unit/concurrent/condition_spec.rb