example.rb

class Scanner
  include Concord.new(:table)

  def scan(threads: 1)
    results = [ ]
    pool = (1..threads).to_a

    workers = pool.map do |i|
      Thread.new do
        response = table.scan(segment: i, total_segments: threads).tap do |data|
          results += data.items
        end

        while response.next_token do
          response = table.scan({
            segment: i,
            total_segments: threads,
            next_token: response.next_token
          }).tap do |data|
            results += data.items
          end
        end
      end
    end

    workers.map(&:join)
    results
  end
end