64 lines
1.8 KiB
C++
64 lines
1.8 KiB
C++
// (C) Copyright 2012 Howard Hinnant
|
|
// (C) Copyright 2012 Vicente Botet
|
|
//
|
|
// 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)
|
|
|
|
// adapted from the example given by Howard Hinnant in
|
|
|
|
#define BOOST_THREAD_VERSION 4
|
|
|
|
#include <iostream>
|
|
#include <boost/thread/scoped_thread.hpp>
|
|
#include <boost/thread/externally_locked_stream.hpp>
|
|
|
|
void use_cerr(boost::externally_locked_stream<std::ostream> &mcerr)
|
|
{
|
|
using namespace boost;
|
|
chrono::steady_clock::time_point tf = chrono::steady_clock::now() + chrono::seconds(10);
|
|
while (chrono::steady_clock::now() < tf)
|
|
{
|
|
mcerr << "logging data to cerr\n";
|
|
this_thread::sleep_for(chrono::milliseconds(500));
|
|
}
|
|
}
|
|
|
|
void use_cout(boost::externally_locked_stream<std::ostream> &mcout)
|
|
{
|
|
using namespace boost;
|
|
chrono::steady_clock::time_point tf = chrono::steady_clock::now() + chrono::seconds(5);
|
|
while (chrono::steady_clock::now() < tf)
|
|
{
|
|
mcout << "logging data to cout\n";
|
|
this_thread::sleep_for(chrono::milliseconds(250));
|
|
}
|
|
}
|
|
|
|
int main()
|
|
{
|
|
using namespace boost;
|
|
|
|
recursive_mutex terminal_mutex;
|
|
|
|
externally_locked_stream<std::ostream> mcerr(std::cerr, terminal_mutex);
|
|
externally_locked_stream<std::ostream> mcout(std::cout, terminal_mutex);
|
|
externally_locked_stream<std::istream> mcin(std::cin, terminal_mutex);
|
|
|
|
scoped_thread<> t1(boost::thread(use_cerr, boost::ref(mcerr)));
|
|
scoped_thread<> t2(boost::thread(use_cout, boost::ref(mcout)));
|
|
this_thread::sleep_for(chrono::seconds(2));
|
|
std::string nm;
|
|
{
|
|
strict_lock<recursive_mutex> lk(terminal_mutex);
|
|
std::ostream & gcout = mcout.get(lk);
|
|
//std::istream & gcin = mcin.get(lk);
|
|
gcout << "Enter name: ";
|
|
//gcin >> nm;
|
|
}
|
|
t1.join();
|
|
t2.join();
|
|
mcout << nm << '\n';
|
|
return 0;
|
|
}
|
|
|