源码提交

libs/log/example/multiple_threads/Jamfile.v2

@@ -0,0 +1,57 @@
+#
+#          Copyright Andrey Semashev 2007 - 2015.
+# Distributed under the Boost Software License, Version 1.0.
+#    (See accompanying file LICENSE_1_0.txt or copy at
+#          http://www.boost.org/LICENSE_1_0.txt)
+#
+
+import ../../build/log-platform-config ;
+
+project
+    : requirements
+        <conditional>@log-platform-config.set-platform-defines
+
+        <link>shared:<define>BOOST_ALL_DYN_LINK
+        <toolset>msvc:<define>_SCL_SECURE_NO_WARNINGS
+        <toolset>msvc:<define>_SCL_SECURE_NO_DEPRECATE
+        <toolset>msvc:<define>_CRT_SECURE_NO_WARNINGS
+        <toolset>msvc:<define>_CRT_SECURE_NO_DEPRECATE
+        <toolset>msvc:<cxxflags>/bigobj
+        <toolset>msvc:<cxxflags>/wd4503 # decorated name length exceeded, name was truncated
+        <toolset>msvc:<cxxflags>/wd4456 # declaration of 'A' hides previous local declaration
+        <toolset>msvc:<cxxflags>/wd4459 # declaration of 'A' hides global declaration
+        <toolset>msvc:<cxxflags>/wd4003 # not enough actual parameters for macro 'X' - caused by BOOST_PP_IS_EMPTY and BOOST_PP_IS_BEGIN_PARENS which are used by Fusion
+        <toolset>intel-win:<define>_SCL_SECURE_NO_WARNINGS
+        <toolset>intel-win:<define>_SCL_SECURE_NO_DEPRECATE
+        <toolset>intel-win:<define>_CRT_SECURE_NO_WARNINGS
+        <toolset>intel-win:<define>_CRT_SECURE_NO_DEPRECATE
+        <toolset>darwin:<cxxflags>-ftemplate-depth-1024
+        <toolset>gcc:<cxxflags>-ftemplate-depth-1024
+        <toolset>gcc:<cxxflags>-fno-strict-aliasing  # avoids strict aliasing violations in other Boost components
+
+        # Disable Intel warnings:
+        # warning #177: function "X" was declared but never referenced
+        # warning #780: using-declaration ignored -- it refers to the current namespace
+        # warning #2196: routine is both "inline" and "noinline"
+        # remark #1782: #pragma once is obsolete. Use #ifndef guard instead.
+        # remark #193: zero used for undefined preprocessing identifier "X"
+        # remark #304: access control not specified ("public" by default)
+        # remark #981: operands are evaluated in unspecified order
+        # remark #1418: external function definition with no prior declaration
+        # Mostly comes from Boost.Phoenix: warning #411: class "X" defines no constructor to initialize the following: reference member "Y"...
+        # warning #734: "X" (declared at line N of "file.hpp"), required for copy that was eliminated, is inaccessible
+        # warning #279: controlling expression is constant
+        <toolset>intel-win:<cxxflags>"/Qwd177,780,2196,1782,193,304,981,1418,411,734,279"
+        <toolset>intel-linux:<cxxflags>"-wd177,780,2196,1782,193,304,981,1418,411,734,279"
+        <toolset>intel-darwin:<cxxflags>"-wd177,780,2196,1782,193,304,981,1418,411,734,279"
+
+        <library>/boost/log//boost_log
+        <library>/boost/date_time//boost_date_time
+        <library>/boost/filesystem//boost_filesystem
+        <library>/boost/thread//boost_thread
+        <threading>multi
+    ;
+
+exe multiple_threads
+    : main.cpp
+    ;

libs/log/example/multiple_threads/main.cpp

@@ -0,0 +1,115 @@
+/*
+ *          Copyright Andrey Semashev 2007 - 2015.
+ * Distributed under the Boost Software License, Version 1.0.
+ *    (See accompanying file LICENSE_1_0.txt or copy at
+ *          http://www.boost.org/LICENSE_1_0.txt)
+ */
+/*!
+ * \file   main.cpp
+ * \author Andrey Semashev
+ * \date   10.06.2008
+ *
+ * \brief  An example of logging in multiple threads.
+ *         See the library tutorial for expanded comments on this code.
+ *         It may also be worthwhile reading the Wiki requirements page:
+ *         http://www.crystalclearsoftware.com/cgi-bin/boost_wiki/wiki.pl?Boost.Logging
+ */
+
+// #define BOOST_LOG_DYN_LINK 1
+
+#include <stdexcept>
+#include <string>
+#include <iostream>
+#include <fstream>
+#include <boost/ref.hpp>
+#include <boost/bind.hpp>
+#include <boost/smart_ptr/shared_ptr.hpp>
+#include <boost/date_time/posix_time/posix_time.hpp>
+#include <boost/thread/thread.hpp>
+#include <boost/thread/barrier.hpp>
+
+#include <boost/log/common.hpp>
+#include <boost/log/expressions.hpp>
+#include <boost/log/attributes.hpp>
+#include <boost/log/sinks.hpp>
+#include <boost/log/sources/logger.hpp>
+
+namespace logging = boost::log;
+namespace attrs = boost::log::attributes;
+namespace src = boost::log::sources;
+namespace sinks = boost::log::sinks;
+namespace expr = boost::log::expressions;
+namespace keywords = boost::log::keywords;
+
+using boost::shared_ptr;
+
+enum
+{
+    LOG_RECORDS_TO_WRITE = 10000,
+    THREAD_COUNT = 2
+};
+
+BOOST_LOG_INLINE_GLOBAL_LOGGER_DEFAULT(test_lg, src::logger_mt)
+
+//! This function is executed in multiple threads
+void thread_fun(boost::barrier& bar)
+{
+    // Wait until all threads are created
+    bar.wait();
+
+    // Now, do some logging
+    for (unsigned int i = 0; i < LOG_RECORDS_TO_WRITE; ++i)
+    {
+        BOOST_LOG(test_lg::get()) << "Log record " << i;
+    }
+}
+
+int main(int argc, char* argv[])
+{
+    try
+    {
+        // Open a rotating text file
+        shared_ptr< std::ostream > strm(new std::ofstream("test.log"));
+        if (!strm->good())
+            throw std::runtime_error("Failed to open a text log file");
+
+        // Create a text file sink
+        shared_ptr< sinks::synchronous_sink< sinks::text_ostream_backend > > sink(
+            new sinks::synchronous_sink< sinks::text_ostream_backend >);
+
+        sink->locked_backend()->add_stream(strm);
+
+        sink->set_formatter
+        (
+            expr::format("%1%: [%2%] [%3%] - %4%")
+                % expr::attr< unsigned int >("RecordID")
+                % expr::attr< boost::posix_time::ptime >("TimeStamp")
+                % expr::attr< attrs::current_thread_id::value_type >("ThreadID")
+                % expr::smessage
+        );
+
+        // Add it to the core
+        logging::core::get()->add_sink(sink);
+
+        // Add some attributes too
+        logging::core::get()->add_global_attribute("TimeStamp", attrs::local_clock());
+        logging::core::get()->add_global_attribute("RecordID", attrs::counter< unsigned int >());
+        logging::core::get()->add_global_attribute("ThreadID", attrs::current_thread_id());
+
+        // Create logging threads
+        boost::barrier bar(THREAD_COUNT);
+        boost::thread_group threads;
+        for (unsigned int i = 0; i < THREAD_COUNT; ++i)
+            threads.create_thread(boost::bind(&thread_fun, boost::ref(bar)));
+
+        // Wait until all action ends
+        threads.join_all();
+
+        return 0;
+    }
+    catch (std::exception& e)
+    {
+        std::cout << "FAILURE: " << e.what() << std::endl;
+        return 1;
+    }
+}