|
@@ -32,7 +32,13 @@ worker(Func, Args, Receiver) ->
|
|
|
ebb_event:return(Receiver, apply(Func, Args)).
|
|
|
|
|
|
worker(Node, Func, Args, Receiver) ->
|
|
|
+ Ref = make_ref(),
|
|
|
+ io:format("~p ~p: Worker thread started~n", [Node, Ref]),
|
|
|
+ {_, _, Start} = erlang:now(),
|
|
|
ebb_event:return(Receiver, apply(Func, Args)),
|
|
|
+ {_, _, Finish} = erlang:now(),
|
|
|
+ io:format("~p ~p: Worker thread finished, time ~p~n",
|
|
|
+ [Node, Ref, Finish-Start]),
|
|
|
ebb_work_manager:work_finished(Node).
|
|
|
|
|
|
stop(Worker) ->
|