A
Тоесть если мне 10таймеров надо то они породят *10 процессов
да 10 спавнов
Size: a a a
2020 July 23
EK
Тоесть если мне 10таймеров надо то они породят *10 процессов
нет, start_timer не порождает процесс, не путать с timer:*
EK
ну в gen_statem нету timer:*
AK
Evgeny Khramtsov
нет, start_timer не порождает процесс, не путать с timer:*
А как же он устроен?
EK
в общем ладно, я по диагонали читаю, сорря
EK
А как же он устроен?
ну через timer_wheel
DF
Как раз в
timer: используется синглтон процесс, который менеджит все таймеры, поэтому он и является боттлнеком.DF
В efficiency guide черным по белому написано же:
> The
> The
timer module uses a separate process to manage the timers. That process can easily become overloaded if many processes create and cancel timers frequently (especially when using the SMP emulator).s
а какая еще?
имутабильность данных))) для меня это +++
V
Evgeny Khramtsov
да, там таймеры убого сделаны, и под нагрузкой в профилировщике это видно
а поконкретнее можно?
A
Как раз в
timer: используется синглтон процесс, который менеджит все таймеры, поэтому он и является боттлнеком.я так понимаю ботлнек только на старт таймеров?
DF
И start и cancel и срабатывание.
EK
а поконкретнее можно?
ну там честные таймеры, а не через receive -> after
V
Evgeny Khramtsov
ну там честные таймеры, а не через receive -> after
их много порождается или в чем конкретно проблема под нагрузкой?
A
timer_timeout(SysTime) ->
case ets:first(?TIMER_TAB) of
'$end_of_table' ->
infinity;
{Time, _Ref} when Time > SysTime ->
Timeout = (Time - SysTime + 999) div 1000,
%% Returned timeout must fit in a small int
erlang:min(Timeout, ?MAX_TIMEOUT);
Key ->
case ets:lookup(?TIMER_TAB, Key) of
[{Key, timeout, MFA}] ->
ets:delete(?TIMER_TAB,Key),
do_apply(MFA),
timer_timeout(SysTime);
[{{Time, Ref}, Repeat = {repeat, Interv, To}, MFA}] ->
ets:delete(?TIMER_TAB,Key),
NewTime = Time + Interv,
%% Update the interval entry (last in table)
ets:insert(?INTERVAL_TAB,{{interval,Ref},{NewTime,Ref},To}),
do_apply(MFA),
ets:insert(?TIMER_TAB, {{NewTime, Ref}, Repeat, MFA}),
timer_timeout(SysTime)
end
end.
V
receive after мне казалось внутри то же будет использовать timer_weel, для after секции. В чем тогда проблема gen_statema?
DF
Табы для индентации, пробелы для выравнивания?..
EK
receive after мне казалось внутри то же будет использовать timer_weel, для after секции. В чем тогда проблема gen_statema?
вроде там не timer_wheel, хотя хз. В любом случае надо сообщение создавать и пихать его в очередь процесса