Asynchronous execution
Async consists on a worker pool for asynchronous execution of tasks (i.e. functions). This utility should be useful for background tasks execution, without risking overloading the system by starting to many process.
Using rebar:
{deps, [
{async, ".*", {git, "https://github.com/jjmrocha/async.git", "master"}}
]}.Async provides a parameter to specify the number of background process for each CPU core (the default value is 1, i.e. in a system with 2 cores the system will start 2 * 1 = 2 process for each job queue).
To change the default value, set value of the property "processes_by_core" on your config file.
[
{async, [
{processes_by_core, 5}
]
}
].Async default job queue is created automatically on the first job.
ok = application:start(async).- Execution of anonymous functions.
async:run(fun() ->
io:format("Hello from ~p~n", [self()])
end).- Execution of function by providing the 3 parameters; ModuleName, FunctionName and Arguments.
async:run(io, format, ["Hello from ~p~n", [self()]]).Async automatically creates custom job queues on the first job submission.
async:run(test_job_queue, fun() ->
io:format("Hello from ~p~n", [self()])
end).
async:run(test_job_queue, io, format, ["Hello from ~p~n", [self()]]).