class DatWorkerPool

  class WorkerPoolSpy
    attr_reader :work_items
    attr_reader :shutdown_called, :shutdown_timeout
    attr_accessor :worker_available

    def initialize
      @worker_available = false
      @work_items = []
      @shutdown_called  = false
      @shutdown_timeout = nil
    end

    def worker_available?
      @worker_available
    end

    def queue_empty?
      @work_items.empty?
    end

    def add_work(work)
      @work_items << work if work
    end

    def shutdown(timeout)
      @shutdown_called = true
      @shutdown_timeout = timeout
    end
  end

end