跨进程加载 DLL - 如何进行某些操作 "singleton-like"

DLL loaded across processes - how to make certain actions "singleton-like"

背景

我正在开发 C++ windows 应用程序。

我的应用程序将打开多个进程。每个进程都会加载一个Logger DLL,它提供了一个接口来注册日志事件并决定何时以及如何将日志刷新到文件中。

问题

假设我在 Logger DLL 中定义了一个简单的决定:每次注册 100 个日志事件时,将它们刷新到文件中。

如何确保刷新仅由一个 DLL 实例执行一次?

当 DLL 跨进程共享并且其中一个操作只需要跨进程执行一次时,最佳实践方法是什么?

备注

我们定义共享内存是至关重要的。每个进程都需要知道其他进程的日志事件。所以,我们不能让每个 DLL 实例都存储自己的日志并单独刷新它们。

我的建议是设置如下内容:

  1. 引入了日志管理器(它可以是专用的独立进程)。他的角色是:

    • 提供监听套接字
    • 时间管理
    • register/unregister 客户
    • 管理哪个实例可以将日志刷新到日志文件。
  2. 每个 DLL 实例:

    • 有自己的日志缓冲区
    • 连接到管理器的套接字(自行注册)
    • 从管理器接收命令以刷新缓冲区。
    • 收到触发器后,将自己的数据附加到日志文件并通知管理器作业已完成。

除了套接字,您还可以使用共享内存(或另一个 API)。我个人觉得sockets比较方便

您的问题并没有说清楚什么是日志记录架构,例如,事件是附加到文件中,还是每次都写入一个新文件?当您将事件写入文件时,它们是否从共享内存中删除?

在大多数情况下,您已经在跟踪(以某种方式)哪些事件已经写入,哪些仍需要写入,因此确定是否有一百个事件未决是微不足道的。您只需要将这些信息放在共享内存块中,并使用适当的同步屏障访问它。

但是,要解决您提出的问题:

Say that I define a simple decision to be made in the Logger DLL: every time a 100 log events were registered, flush them to a file.

您可以使用一个简单的计数器来完成此操作,当然是在共享内存中。如果由于某种原因你不能把它放在现有的共享内存块中,你可以创建一个单独的。


如果您已经受到互斥体的保护,这很简单:

void count_new_event()
{
    if ((*counter)++ == 100) 
    {
       flush_events();
       (*counter) = 0;
    }
}   

如果你想避免申请互斥体,你可以这样做:

void count_new_event()
{
    for (;;)
    {
        DWORD count = InterlockedCompareExchange(counter, 0, 99);
        if (count == 99)
        {
            // The count was 99, so this is the 100th call
            // The call to InterlockedCompareExchange reset the counter
            flush_events();
            break;
        }
        else
        {
            if (InterlockedCompareExchange(counter, count + 1, count) == count)
            {
                // We've successfully incremented the counter
                break;
            }
            else
            {
                // Oops, someone got in before us; try again
                continue;
            }
        }
    }
}

请注意,我尚未测试此代码,而且它也不一定是最有效的方法。但它应该适用于大多数情况,如果您还没有互斥锁,它会比申请互斥锁更有效。

另请注意,我假设 flush_events 将处理不同进程对它的调用重叠的情况。这可能就像让它声明互斥锁一样简单。如果不是,例如,如果一次刷新一百个事件可能不足以跟上新事件的速度,那么您几乎可以肯定地跟踪哪些事件需要写入会更好。


如果你想定期刷新日志,你可以做类似的事情,比如说一分钟一次,而不是每一百个事件。只需在共享内存中记录最后一次刷新的时间戳,并将其与当前时间进行比较。如果不想认领互斥锁,可以使用InterlockedCompareExchange更新时间戳;对 InterlockedCompareExchange 的调用只会在一个进程中成功,因此这就是执行刷新的进程。