c++ - 需要知道如何检查输入的字符串是否已在 C++ 中的线程安全记录器中终止

Question

我对此很陌生，如果我的问题不清楚，我深表歉意。

我用 C++ 创建了一个线程安全的记录器。该记录器将在大型程序中使用，并将从多个地方调用。我使用的是单例，因此只有一个记录器实例。此记录器输出到文件和控制台。它的行为类似于 cout；它从另一个文件中获取一个字符串，(必要时将其连接起来)，将这些字符串存储在缓冲区中，直到字符串完成，然后使用 cout 输出。该字符串被存储为 const char*。现在，互斥锁在一个函数中被锁定并在另一个函数中解锁(这是我的问题)，这使 endl 运算符过载。

我的问题是，只有当用户在调用记录器的其他文件中写入 endl 时，此函数(其中互斥量已解锁)才有效。我需要这是一个通用的实用程序，它不会依赖于用户编写的内容，因为用户可能不会使用 endl 或可能会经常使用它。我现在需要一些方法让我的记录器识别字符串(来自另一个文件)何时完成，以便它可以清空缓冲区。目前 endl 就像一个关键字，我需要一些方法让它在没有任何关键字的情况下工作。

我最初想我可以找到一些方法来检查字符串中的“\0”终止字符，然后使用该检查知道字符串已完成，然后清空缓冲区。但是，当我这样做时，我会遇到越界错误。

谢谢你的时间

Answer 1

我不太确定我了解情况，但听起来您想要一个代理:

class LogSingleton
{
public:
    LogSingleton& instance() { /* ... */ }

    void lock(); // lock mutex
    void unlock(); // unlock mutex

    template <typename T>
    friend LogSingleton& operator<<(LogSingleton& pLog, const T& pX)
    {
        // needs to be locked first
        assert(is_locked()); 

        /* output pX however */

        return pLog;
    }
};

class LogProxy
{
public:
    LogProxy()
    {
        // manage lock in proxy
        LogSingleton::instance().lock();            
    }

    ~LogProxy()
    {
        LogSingleton::instance().unlock();            
    }
};

// forward input into the proxy to the log, knowing it's locked
template <typename T>
LogProxy& operator<<(LogProxy& pProxy, const T& pX)
{
    LogSingleton::instance() << pX;

    return pProxy;
}

// now expose proxy
typedef LogProxy log;

你会这样做:

log() << "its locked now" << "and the temporary will die" << "here ->";

加锁在构造函数和析构函数中完成，最后调用析构函数。

---

正如 Tony 正确指出的那样，这会不必要地延长锁定时间。只有“最终”输出到 LogSingleton 才需要锁。想象一下:

log() << "this next function takes 5 minutes"
        << my_utterly_crappy_function() << "ouch";

尚未记录任何内容，但互斥量已锁定很长时间。更好的办法是缓冲输出然后一次输出所有内容:

class LogProxy
{
public:
    ~LogProxy()
    {
        // manage lock in proxy
        LogSingleton::instance().lock();

        // no-throw, or wrap mutex use in a scoped-lock
        LogSingleton::instance() << mBuffer.rdbuf();

        LogSingleton::instance().unlock();            
    }

    // buffer output
    template <typename T>
    friend LogProxy& operator<<(LogProxy& pProxy, const T& pX)
    {
        mBuffer << pX;

        return pProxy;
    }

private:
    std::ostringstream mBuffer;
};

现在在缓冲区准备好输出之前不会获取任何锁。