diff options
| -rw-r--r-- | src/worker_pool_worker.erl | 15 |
1 files changed, 7 insertions, 8 deletions
diff --git a/src/worker_pool_worker.erl b/src/worker_pool_worker.erl index d3942a1b6e..57901fd5cf 100644 --- a/src/worker_pool_worker.erl +++ b/src/worker_pool_worker.erl @@ -48,7 +48,8 @@ -spec(submit/2 :: (pid(), fun (() -> A) | {atom(), atom(), [any()]}) -> A). -spec(submit_async/2 :: (pid(), fun (() -> any()) | {atom(), atom(), [any()]}) -> 'ok'). - +-spec(run/1 :: (fun (() -> A)) -> A; + ({atom(), atom(), [any()]}) -> any()). -spec(set_maximum_since_use/2 :: (pid(), non_neg_integer()) -> 'ok'). -endif. @@ -72,6 +73,11 @@ submit_async(Pid, Fun) -> set_maximum_since_use(Pid, Age) -> gen_server2:pcast(Pid, 8, {set_maximum_since_use, Age}). +run({M, F, A}) -> + apply(M, F, A); +run(Fun) -> + Fun(). + %%---------------------------------------------------------------------------- init([WId]) -> @@ -110,10 +116,3 @@ code_change(_OldVsn, State, _Extra) -> terminate(_Reason, State) -> State. - -%%---------------------------------------------------------------------------- - -run({M, F, A}) -> - apply(M, F, A); -run(Fun) -> - Fun(). |