并行跑

lib/tasks/statistic_subject_info.rake

@@ -125,7 +125,7 @@ namespace :subjects do
     subjects.find_each(batch_size: 50) do |subject|
       puts("---------------------user_info_statistic: #{subject.id}")
       data = Subjects::UserUsedInfoService.call(subject)
-      Parallel.each(data) do |key|
+      Parallel.each(data, in_processes: 5) do |key|
         next if key[:user_id].nil?
         str += ", " unless str.empty?
         str += ("(#{key[:user_id]}, #{subject.id}, '#{key[:name].gsub(/'/, '"')}', #{key[:passed_myshixun_count]}, " +