Contents

# frozen_string_literal: true

module WSDirector
  # Acts as a re-usable global barrier for a fixed number of clients.
  # Barrier is reset if sucessfully passed in time.
  class ClientsHolder
    def initialize(count, sync_timeout: 5)
      @barrier = Concurrent::CyclicBarrier.new(count)
      @sync_timeout = sync_timeout
    end

    def wait_all
      result = barrier.wait(sync_timeout)
      raise Error, "Timeout (#{sync_timeout}s) exceeded for #wait_all" unless
        result
      barrier.reset
      result
    end

    private

    attr_reader :barrier, :sync_timeout
  end
end

Version data entries

5 entries across 5 versions & 1 rubygems

Version	Path
wsdirector-core-1.1.0	lib/wsdirector/clients_holder.rb
wsdirector-core-1.0.3	lib/wsdirector/clients_holder.rb
wsdirector-core-1.0.2	lib/wsdirector/clients_holder.rb
wsdirector-core-1.0.1	lib/wsdirector/clients_holder.rb
wsdirector-core-1.0.0	lib/wsdirector/clients_holder.rb