RSpec.shared_examples :count_down_latch do

  let(:latch) { described_class.new(3) }
  let(:zero_count_latch) { described_class.new(0) }

  context '#initialize' do

    it 'raises an exception if the initial count is less than zero' do
      expect {
        described_class.new(-1)
      }.to raise_error(ArgumentError)
    end

    it 'raises an exception if the initial count is not an integer' do
      expect {
        described_class.new('foo')
      }.to raise_error(ArgumentError)
    end

    it 'defaults the count to 1' do
      latch = described_class.new
      expect(latch.count).to eq 1
    end
  end

  describe '#count' do

    it 'should be the value passed to the constructor' do
      expect(latch.count).to eq 3
    end

    it 'should be decreased after every count down' do
      latch.count_down
      expect(latch.count).to eq 2
    end

    it 'should not go below zero' do
      5.times { latch.count_down }
      expect(latch.count).to eq 0
    end
  end

  describe '#wait' do

    it 'blocks indefinitely, and is kill-able' do
      t = in_thread(latch) { |l| l.wait }
      is_sleeping t
    end

    it 'blocks indefinitely with timeout, and is kill-able' do
      t = in_thread(latch) { |l| l.wait 100 }
      is_sleeping t
    end

    context 'count set to zero' do
      it 'should return true immediately' do
        result = zero_count_latch.wait
        expect(result).to be_truthy
      end

      it 'should return true immediately with timeout' do
        result = zero_count_latch.wait(5)
        expect(result).to be_truthy
      end
    end

    context 'non zero count' do

      it 'should block thread until counter is set to zero' do
        3.times do
          in_thread { sleep(0.1); latch.count_down }
        end

        result = latch.wait
        expect(result).to be_truthy
        expect(latch.count).to eq 0
      end

      it 'should block until counter is set to zero with timeout' do
        3.times do
          in_thread { sleep(0.1); latch.count_down }
        end

        result = latch.wait(1)
        expect(result).to be_truthy
        expect(latch.count).to eq 0
      end

      it 'should block until timeout and return false when counter is not set to zero' do
        result = latch.wait(0.1)
        expect(result).to be_falsey
        expect(latch.count).to eq 3
      end
    end
  end
end

module Concurrent

  RSpec.describe MutexCountDownLatch do

    it_should_behave_like :count_down_latch

    context 'spurious wake ups' do

      subject { described_class.new(3) }

      before(:each) do
        def subject.simulate_spurious_wake_up
          synchronize do
            ns_signal
            ns_broadcast
          end
        end
      end

      it 'should resist to spurious wake ups without timeout' do
        latch    = Concurrent::CountDownLatch.new(1)
        expected = false

        t = in_thread do
          latch.wait(1)
          subject.wait
          expected = true
        end

        latch.count_down
        t.join(0.1)
        subject.simulate_spurious_wake_up

        t.join(0.1)
        expect(expected).to be_falsey
      end

      it 'should resist to spurious wake ups with timeout' do
        start_latch  = Concurrent::CountDownLatch.new(1)
        finish_latch = Concurrent::CountDownLatch.new(1)
        expected     = false

        t = in_thread do
          start_latch.wait(1)
          subject.wait(0.5)
          expected = true
          finish_latch.count_down
        end

        start_latch.count_down
        t.join(0.1)
        subject.simulate_spurious_wake_up

        t.join(0.1)
        expect(expected).to be_falsey

        finish_latch.wait(1)
        expect(expected).to be_truthy
      end
    end
  end

  if Concurrent.on_jruby?
    RSpec.describe JavaCountDownLatch do
      it_should_behave_like :count_down_latch
    end
  end

  RSpec.describe CountDownLatch do
    if Concurrent.on_jruby?
      it 'inherits from JavaCountDownLatch' do
        expect(CountDownLatch.ancestors).to include(JavaCountDownLatch)
      end
    else
      it 'inherits from MutexCountDownLatch' do
        expect(CountDownLatch.ancestors).to include(MutexCountDownLatch)
      end
    end
  end
end