Merge branch 'Eein-1058/fix-slow-multicore-performance'

lib/credo/check.ex

@@ -393,8 +393,11 @@ defmodule Credo.Check do
 
       defp do_run_on_all_source_files(exec, source_files, params) do
         source_files
-        |> Enum.map(&Task.async(fn -> run_on_source_file(exec, &1, params) end))
-        |> Enum.each(&Task.await(&1, :infinity))
+        |> Task.async_stream(fn source -> run_on_source_file(exec, source, params) end,
+          max_concurrency: exec.max_concurrent_check_runs,
+          timeout: :infinity
+        )
+        |> Stream.run()
 
         :ok
       end

lib/credo/check/runner.ex

@@ -19,9 +19,14 @@ defmodule Credo.Check.Runner do
       |> warn_about_ineffective_patterns(exec)
       |> fix_deprecated_notation_for_checks_without_params()
 
-    Credo.Check.Worker.run(check_tuples, exec.max_concurrent_check_runs, fn check_tuple ->
-      run_check(exec, check_tuple)
-    end)
+    check_tuples
+    |> Task.async_stream(
+      fn check_tuple ->
+        run_check(exec, check_tuple)
+      end,
+      timeout: :infinity
+    )
+    |> Stream.run()
 
     :ok
   end

lib/credo/execution.ex

@@ -42,13 +42,15 @@ defmodule Credo.Execution do
             enable_disabled_checks: nil,
             ignore_checks_tags: [],
             ignore_checks: nil,
-            max_concurrent_check_runs: nil,
             min_priority: 0,
             mute_exit_status: false,
             only_checks_tags: [],
             only_checks: nil,
             read_from_stdin: false,
 
+            # This is no longer used, but we keep it so existing plugins that use it don't break
+            max_concurrent_check_runs: nil,
+
             # state, which is accessed and changed over the course of Credo's execution
             pipeline_map: %{},
             commands: %{},