如何从 boost log sink 组织线程安全读取？

Posted 2023-02-17

【中文标题】如何从 boost log sink 组织线程安全读取？

【英文标题】：How to organize thread safe reading from boost log sink?

【发布时间】：2018-08-14 15:06:45

【问题描述】：

我正在寻找一种正确的方法来安全地从 boost::log::sinks::text_ostream_backend 获取文本数据。 我目前只有在所有内容都记录在接收器后端之后才能获取数据。我想获取后端内部缓冲区（m_ss）的副本，同时仍然可以生成数据。

using Logger = boost::log::sources::severity_channel_logger_mt<boost::log::trivial::severity_level, std::string>;

class MyClass

  mutable std::mutex  m_mutex;
  mutable Logger      m_logger boost::log::keywords::channel = "MyClass";
  std::stringstream   m_ss;
  bool                m_completed false;

public:
  void initLogging(const std::string& id)
  
    using namespace boost::log;
    using Sink = sinks::synchronous_sink<sinks::text_ostream_backend>;

    auto backend = boost::make_shared<sinks::text_ostream_backend>();
    backend->add_stream(boost::shared_ptr<std::stringstream>(&m_ss, boost::null_deleter()));
    auto sink = boost::make_shared<Sink>(backend);
    sink->set_filter(expressions::has_attr<std::string>("ID") && expressions::attr<std::string>("ID") == id);

    core::get()->add_sink(sink);

    m_logger.add_attribute("ID", attributes::constant<std::string>(id));
  

  void doSomething()
  
    BOOST_LOG_SEV(logger, boost::log::trivial::severity_level::debug) << "TEST";
    BOOST_LOG_SEV(logger, boost::log::trivial::severity_level::error) << "TEST";

    // Stop write logs
    std::lock_guard<std::mutex> lock(m_mutex);
    m_completed = true;
  

  void access()
  
    std::lock_guard<std::mutex> lock(m_mutex);

    if (m_completed) 
      // Can read from stream
      useStreamData(m_ss.str());
    
  
;

【参考方案1】：

如果流仅由接收器后端访问，那么同步访问的最简单方法是使用locked_backend。

auto locked_backend = sink->locked_backend();

这里，locked_backend 对象是一个智能指针，它锁定接收器前端，因此阻止日志记录线程访问后端，从而阻止 m_ss 流。当locked_backend 存在时，您可以安全地使用m_ss。

还有其他方法可以实现这一点。例如，您可以实现custom sink backend 或实现允许同步访问累积数据的流缓冲区。有许多关于编写自定义流缓冲区的文章和博客文章，here 就是一个例子。