class SplitIoClient::Cache::Adapters::MemoryAdapters::QueueAdapter

def get_batch(size)
  items = []
  size.times do
    items << @queue.pop(true)
    @current_size.decrement
  end
  items
  rescue ThreadError
  items
end