Module worker_pool_worker

Behaviours: gen_server2.

Data Types

mfargs()

mfargs() = {atom(), atom(), [any()]}

Function Index

clear_timeout/1
code_change/3
handle_call/3
handle_cast/2
handle_info/2
init/1
next_job_from/2
prioritise_cast/3
run/1
set_maximum_since_use/2
set_timeout/2
set_timeout/3
start_link/1
submit/3
submit_async/2
terminate/2

Function Details

clear_timeout/1

clear_timeout(Key::any()) -> ok

code_change/3

code_change(OldVsn, State, Extra) -> any()

handle_call/3

handle_call(Msg, From, State) -> any()

handle_cast/2

handle_cast(Msg, State) -> any()

handle_info/2

handle_info(Msg, State) -> any()

init/1

init(X1) -> any()

next_job_from/2

next_job_from(Pid::pid(), CPid::pid()) -> ok

prioritise_cast/3

prioritise_cast(Msg, Len, State) -> any()

run/1

run(Fun::fun(() -> A)) -> A

run(Fun::mfargs()) -> any()

set_maximum_since_use/2

set_maximum_since_use(Pid::pid(), Age::non_neg_integer()) -> ok

set_timeout/2

set_timeout(Time::non_neg_integer(), Fun::fun(() -> any())) -> {ok, reference()}

set_timeout/3

set_timeout(Key, Time::non_neg_integer(), Fun::fun(() -> any())) -> {ok, Key}

start_link/1

start_link(PoolName::atom) -> {ok, pid()} | {error, any()}

submit/3

submit(Pid::pid(), Fun::fun(() -> A) | mfargs(), ProcessModel::reuse | single) -> A

submit_async/2

submit_async(Pid::pid(), Fun::fun(() -> any()) | mfargs()) -> ok

terminate/2

terminate(Reason, State) -> any()


Generated by EDoc