为什么要这样设计？

Question

我在使用啤酒时遇到了问题。 在 lager 源代码中，lager_backend_throttle.erl 文件。

handle_event({log, _Message},State) ->
    {message_queue_len, Len} = erlang:process_info(self(), message_queue_len),
    case {Len > State#state.hwm, State#state.async} of
        {true, true} ->
            %% need to flip to sync mode
            lager_config:set(async, false),
            {ok, State#state{async=false}};
        {false, false} ->
            %% need to flip to async mode
            lager_config:set(async, true),
            {ok, State#state{async=true}};
        _ ->
            %% nothing needs to change
            {ok, State}
    end;

当 message_queue_len 大于 Threshold 时，它会翻转到同步模式。

当message_queue_len小于Thershold时，会转为异步模式。

我认为当消息太多时，应该将模式更改为异步以更快地处理消息。为什么要以这种方式进行大型设计？

我猜测的原因是message_queue中存在限制长度，如果消息太多，进程可能会崩溃。所以较大的通过改变发送模式来降低发送消息的速度？

Answer 1

我在github上找到了答案。

在 lager 2.0 之前，lager 核心的 gen_event 纯粹以同步模式运行。异步模式更快，但无法防止消息队列过载。在 lager 2.0 中，gen_event 采用混合方法。它轮询自己的邮箱大小，并根据邮箱大小在同步和异步之间切换消息传递。

{async_threshold, 20}, {async_threshold_window, 5} 这将使用异步消息传递，直到邮箱超过 20 条消息，此时将使用同步消息传递，并在大小减小到 20 - 5 = 15 时切换回异步。

如果您希望禁用此行为，只需将其设置为“未定义”。它默认为一个较小的数字，以防止邮箱快速增长超过限制并导致问题。一般来说，lager 应该尽快处理消息，因此落后 20 应该是相对例外的。

如果您想限制 error_logger 每秒允许的消息数量，如果您想在大量相关进程崩溃时抵御大量消息，这是一个好主意，您可以设置一个限制：

{error_logger_hwm, 50} 最好保持这个数字很小。