parallel + retry-handlerのサンプルコード

parallel_with_retry-handler.rb

    Parallel.each(last_infos, :in_threads => 4){ |last_info|
      begin
        Proc.new do
          timeout(20) do
            Peercast::Screenshot.new(last_info.url).download_to(download_path)
          end

          last_info.capture = download_path
          last_info.save
        end.retry(:max => 3, :accept_exception => Timeout::Error, :logger => Logger.new(STDERR))
      rescue RetryOverError
        STDERR.puts "reach retry max count"
      rescue => ex
        STDERR.puts "other error"
        STDERR.puts ex
      end
    }