lib/parallel_stream/defaults.ex
defmodule ParallelStream.Defaults do
def num_workers do
:erlang.system_info(:schedulers) * 2
end
def worker_work_ratio do
5
end
end
defmodule ParallelStream.Defaults do
def num_workers do
:erlang.system_info(:schedulers) * 2
end
def worker_work_ratio do
5
end
end