hugo/bDS2
1
0
Fork 0
Code Issues 4 Pull Requests Actions Packages Projects Releases Wiki Activity

fix: allow greater concurrency

Browse Source
This commit is contained in:
Chili Palmer
2026-07-02 21:59:36 +02:00
parent 4b52ac6156
commit 1917043c10
1 changed files with 8 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
lib/bds/tasks.ex
View File

@@ -10,7 +10,6 @@ defmodule BDS.Tasks do
@type progress_reporter :: (number(), String.t() | nil -> any()) @type progress_reporter :: (number(), String.t() | nil -> any())
@type task_work :: (progress_reporter() -> term()) @type task_work :: (progress_reporter() -> term())
@default_max_concurrent 3
@default_progress_throttle_ms 250 @default_progress_throttle_ms 250
@default_recent_finished_limit 10 @default_recent_finished_limit 10
@default_finished_task_ttl_ms :timer.hours(1) @default_finished_task_ttl_ms :timer.hours(1)
@@ -512,9 +511,16 @@ defmodule BDS.Tasks do
defp max_concurrent do defp max_concurrent do
Application.get_env(:bds, :tasks, []) Application.get_env(:bds, :tasks, [])
|> Keyword.get(:max_concurrent, @default_max_concurrent) |> Keyword.get(:max_concurrent, default_max_concurrent())
end end
# The original TypeScript task manager hard-capped concurrency at 3 because it
# ran on a single-threaded event loop. The BEAM schedules processes across
# every CPU core, so the default tracks the number of online schedulers
# (cores) instead — letting all render-site sections run in parallel. Override
# with `config :bds, :tasks, max_concurrent: N`.
defp default_max_concurrent, do: System.schedulers_online()
defp progress_throttle_ms do defp progress_throttle_ms do
Application.get_env(:bds, :tasks, []) Application.get_env(:bds, :tasks, [])
|> Keyword.get(:progress_throttle_ms, @default_progress_throttle_ms) |> Keyword.get(:progress_throttle_ms, @default_progress_throttle_ms)