线程执行

lib/tasks/statistic_subject_info.rake

@@ -124,10 +124,10 @@ namespace :subjects do
         "code_line_count, evaluate_count, cost_time, created_at, updated_at"
 
     subjects.find_in_batches(batch_size: 50) do |s|
-      Parallel.each(s, in_processes: 10) do |subject|
+      Parallel.each(s, in_processes: 5) do |subject|
         puts("---------------------user_info_statistic: #{subject.id}")
         data = Subjects::UserUsedInfoService.call(subject)
-        Parallel.each(data, in_processes: 10) do |key|
+        data.each 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]}, " +