diff options
| author | Alexandru Scvortov <alexandru@rabbitmq.com> | 2011-09-09 10:22:05 +0100 |
|---|---|---|
| committer | Alexandru Scvortov <alexandru@rabbitmq.com> | 2011-09-09 10:22:05 +0100 |
| commit | 469f08821744d07be23cad7e7b22a5c4d040e953 (patch) | |
| tree | 42fa8b33b1277e3f19e03b3ec73006a64f85639a /src | |
| parent | adc12772ebe9591f78f81f7449ceeb8453653cf4 (diff) | |
| download | rabbitmq-server-git-469f08821744d07be23cad7e7b22a5c4d040e953.tar.gz | |
refactor + handle MFAs
Diffstat (limited to 'src')
| -rw-r--r-- | src/worker_pool.erl | 12 |
1 files changed, 4 insertions, 8 deletions
diff --git a/src/worker_pool.erl b/src/worker_pool.erl index bdcafc8419..af5e289688 100644 --- a/src/worker_pool.erl +++ b/src/worker_pool.erl @@ -61,14 +61,10 @@ start_link() -> submit(Fun) -> %% If the worker_pool is not running, just run the Fun in the %% current process. - case whereis(?SERVER) of - undefined -> Fun(); - _ -> case get(worker_pool_worker) of - true -> worker_pool_worker:run(Fun); - _ -> Pid = gen_server2:call(?SERVER, next_free, - infinity), - worker_pool_worker:submit(Pid, Fun) - end + case get(worker_pool_worker) =:= true orelse whereis(?SERVER) =:= undefined of + true -> worker_pool_worker:run(Fun); + false -> Pid = gen_server2:call(?SERVER, next_free, infinity), + worker_pool_worker:submit(Pid, Fun) end. submit_async(Fun) -> |
