diff options
| author | Matthew Sackman <matthew@lshift.net> | 2010-04-30 16:21:30 +0100 |
|---|---|---|
| committer | Matthew Sackman <matthew@lshift.net> | 2010-04-30 16:21:30 +0100 |
| commit | b4b40403d6d3a8431ec174e15bea84a1b0f615dc (patch) | |
| tree | 8db6ec6c3b1d532af89130aaf45c5988fa32b3af /src | |
| parent | 9612925dd09b90cb88595e5a31ba681aab2f131a (diff) | |
| parent | b57ebc9d104ab2db4b44b874181db1cf21ecd2c2 (diff) | |
| download | rabbitmq-server-git-b4b40403d6d3a8431ec174e15bea84a1b0f615dc.tar.gz | |
Merging default into bug22616
Diffstat (limited to 'src')
| -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(). |