如何在 Erlang 中定期执行操作

Question

-define(INTERVAL, 1000).

init([]) ->
    Timer = erlang:send_after(?INTERVAL, self(), tick),
    {ok, Timer}.

handle_info(tick, OldTimer) ->
    erlang:cancel_timer(OldTimer),
    io:format("Tick ~w~n", [OldTimer]),
    Timer = erlang:send_after(?INTERVAL, self(), tick).
    {noreplay, Timer}.

start_clock() ->
    {_, Timer} = init([]),
    spawn(clock, handle_info, [tick, Timer]).

我的代码如上，但输出不是我想要的。 如何将 init() 和 handle_info() 集成到主函数(start_clock) 中？

Answer 1

在timer模块中，函数apply_interval(Time, Module, Function, Arguments)每隔时间间隔执行一次Module:Function(Arguments)。它负责生成一个进程，返回一个引用以允许稍后取消。

您也可以在同一个库中查看send_interval(Time, Pid, Message)。

您还可以实现一个简单的循环，例如：

loop(Args,Tick) when is_integer(Tick), Tick >= 0 ->
    receive
        stop -> stopped
    after Tick
        do_something(Args),
        {NewArgs,NewTick} = new_args(Args,Tick), 
        loop(NewArgs,NewTick)
    end.

它不是实时定时器，但函数 new_args(Args,Tick) 可以帮助纠正由于进程调度造成的偏差。

Answer 2

我认为你需要这样的东西：

start_timer() ->
    gen_server:start_link({local, clock}, ?MODULE, [], []).