331 lines
12 KiB
C++
331 lines
12 KiB
C++
// Copyright (C) 2012-2013 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)
|
|
|
|
#include <boost/config.hpp>
|
|
|
|
#if ! defined BOOST_NO_CXX11_DECLTYPE
|
|
#define BOOST_RESULT_OF_USE_DECLTYPE
|
|
#endif
|
|
|
|
|
|
#define BOOST_THREAD_VERSION 4
|
|
//#define BOOST_THREAD_USES_LOG
|
|
#define BOOST_THREAD_USES_LOG_THREAD_ID
|
|
|
|
#include <boost/thread/future.hpp>
|
|
#include <boost/thread/csbl/vector.hpp>
|
|
#include <boost/assert.hpp>
|
|
#include <boost/thread/detail/log.hpp>
|
|
#include <string>
|
|
#if defined BOOST_THREAD_PROVIDES_FUTURE_WHEN_ALL_WHEN_ANY
|
|
|
|
#ifdef BOOST_MSVC
|
|
#pragma warning(disable: 4127) // conditional expression is constant
|
|
#endif
|
|
|
|
int p1()
|
|
{
|
|
BOOST_THREAD_LOG
|
|
<< "P1" << BOOST_THREAD_END_LOG;
|
|
boost::this_thread::sleep_for(boost::chrono::seconds(1));
|
|
return 123;
|
|
}
|
|
int p1b()
|
|
{
|
|
BOOST_THREAD_LOG
|
|
<< "P1b" << BOOST_THREAD_END_LOG;
|
|
boost::this_thread::sleep_for(boost::chrono::seconds(1));
|
|
return 321;
|
|
}
|
|
|
|
int p2(boost::future<int> f)
|
|
{
|
|
BOOST_THREAD_LOG
|
|
<< " P2 " << BOOST_THREAD_END_LOG;
|
|
try
|
|
{
|
|
return 2 * f.get();
|
|
}
|
|
catch (std::exception& ex)
|
|
{
|
|
BOOST_THREAD_LOG
|
|
<< "ERRORRRRR " << ex.what() << "" << BOOST_THREAD_END_LOG;
|
|
BOOST_ASSERT(false);
|
|
}
|
|
catch (...)
|
|
{
|
|
BOOST_THREAD_LOG
|
|
<< " ERRORRRRR exception thrown" << BOOST_THREAD_END_LOG;
|
|
BOOST_ASSERT(false);
|
|
}
|
|
BOOST_THREAD_LOG
|
|
<< "P2>" << BOOST_THREAD_END_LOG;
|
|
return 0;
|
|
|
|
}
|
|
int p2s(boost::shared_future<int> f)
|
|
{
|
|
BOOST_THREAD_LOG
|
|
<< "<P2" << BOOST_THREAD_END_LOG;
|
|
try
|
|
{
|
|
return 2 * f.get();
|
|
}
|
|
catch (std::exception& ex)
|
|
{
|
|
BOOST_THREAD_LOG
|
|
<< "ERRORRRRR " << ex.what() << "" << BOOST_THREAD_END_LOG;
|
|
BOOST_ASSERT(false);
|
|
}
|
|
catch (...)
|
|
{
|
|
BOOST_THREAD_LOG
|
|
<< " ERRORRRRR exception thrown" << BOOST_THREAD_END_LOG;
|
|
BOOST_ASSERT(false);
|
|
}
|
|
BOOST_THREAD_LOG
|
|
<< "P2>" << BOOST_THREAD_END_LOG;
|
|
return 0;
|
|
}
|
|
|
|
int main()
|
|
{
|
|
BOOST_THREAD_LOG
|
|
<< "<MAIN" << BOOST_THREAD_END_LOG;
|
|
{
|
|
try
|
|
{
|
|
{
|
|
BOOST_THREAD_LOG << BOOST_THREAD_END_LOG;
|
|
boost::future<boost::csbl::tuple<> > all0 = boost::when_all();
|
|
BOOST_THREAD_LOG
|
|
<< BOOST_THREAD_END_LOG;
|
|
}
|
|
{
|
|
BOOST_THREAD_LOG << BOOST_THREAD_END_LOG;
|
|
boost::future<int> f1 = boost::async(boost::launch::async, &p1);
|
|
boost::future<boost::csbl::tuple<boost::future<int> > > all = boost::when_all(boost::move(f1));
|
|
boost::csbl::tuple<boost::future<int> > res = all.get();
|
|
BOOST_THREAD_LOG
|
|
<< boost::csbl::get<0>(res).get() <<" " << BOOST_THREAD_END_LOG;
|
|
}
|
|
#if defined(BOOST_THREAD_PROVIDES_VARIADIC_THREAD)
|
|
{
|
|
BOOST_THREAD_LOG << BOOST_THREAD_END_LOG;
|
|
boost::future<int> f1 = boost::async(boost::launch::deferred, &p1);
|
|
BOOST_THREAD_LOG << BOOST_THREAD_END_LOG;
|
|
boost::future<boost::csbl::tuple<boost::future<int> > > all = boost::when_all(boost::move(f1));
|
|
BOOST_THREAD_LOG << BOOST_THREAD_END_LOG;
|
|
boost::csbl::tuple<boost::future<int> > res = all.get();
|
|
BOOST_THREAD_LOG
|
|
<< boost::csbl::get<0>(res).get() <<" " << BOOST_THREAD_END_LOG;
|
|
}
|
|
#endif
|
|
{
|
|
BOOST_THREAD_LOG << BOOST_THREAD_END_LOG;
|
|
boost::future<int> f1 = boost::make_ready_future(1);
|
|
boost::future<boost::csbl::tuple<boost::future<int> > > all = boost::when_all(boost::move(f1));
|
|
boost::csbl::tuple<boost::future<int> > res = all.get();
|
|
BOOST_THREAD_LOG
|
|
<< boost::csbl::get<0>(res).get() <<" " << BOOST_THREAD_END_LOG;
|
|
}
|
|
{
|
|
BOOST_THREAD_LOG << BOOST_THREAD_END_LOG;
|
|
boost::future<int> f1 = boost::async(boost::launch::async, &p1);
|
|
boost::future<int> f2 = boost::async(boost::launch::async, &p1b);
|
|
boost::future<boost::csbl::tuple<boost::future<int>,boost::future<int> > > all = boost::when_all(boost::move(f1), boost::move(f2));
|
|
//(void) all.wait();
|
|
boost::csbl::tuple<boost::future<int>,boost::future<int> > res = all.get();
|
|
BOOST_THREAD_LOG
|
|
<< boost::csbl::get<0>(res).get() <<" " << BOOST_THREAD_END_LOG;
|
|
BOOST_THREAD_LOG
|
|
<< boost::csbl::get<1>(res).get() <<" " << BOOST_THREAD_END_LOG;
|
|
}
|
|
{
|
|
BOOST_THREAD_LOG << BOOST_THREAD_END_LOG;
|
|
boost::future<int> f1 = boost::async(boost::launch::async, &p1);
|
|
boost::future<std::string> f2 = boost::make_ready_future(std::string("nnnnnnn"));;
|
|
boost::future<boost::csbl::tuple<boost::future<int>, boost::future<std::string> > > all = boost::when_all(boost::move(f1), boost::move(f2));
|
|
//(void) all.wait();
|
|
boost::csbl::tuple<boost::future<int>, boost::future<std::string> > res = all.get();
|
|
BOOST_THREAD_LOG
|
|
<< boost::csbl::get<0>(res).get() <<" " << BOOST_THREAD_END_LOG;
|
|
BOOST_THREAD_LOG
|
|
<< boost::csbl::get<1>(res).get() <<" " << BOOST_THREAD_END_LOG;
|
|
}
|
|
{
|
|
BOOST_THREAD_LOG << BOOST_THREAD_END_LOG;
|
|
boost::csbl::vector<boost::future<int> > v;
|
|
BOOST_THREAD_LOG << BOOST_THREAD_END_LOG;
|
|
v.push_back(boost::async(boost::launch::async, &p1));
|
|
BOOST_THREAD_LOG << BOOST_THREAD_END_LOG;
|
|
v.push_back(boost::async(boost::launch::async, &p1b));
|
|
BOOST_THREAD_LOG << BOOST_THREAD_END_LOG;
|
|
boost::future<boost::csbl::vector<boost::future<int> > > all = boost::when_all(v.begin(), v.end());
|
|
BOOST_THREAD_LOG << BOOST_THREAD_END_LOG;
|
|
boost::csbl::vector<boost::future<int> > res = all.get();
|
|
BOOST_THREAD_LOG
|
|
<< res[0].get() <<" " << BOOST_THREAD_END_LOG;
|
|
BOOST_THREAD_LOG
|
|
<< res[1].get() <<" " << BOOST_THREAD_END_LOG;
|
|
}
|
|
}
|
|
catch (std::exception& ex)
|
|
{
|
|
BOOST_THREAD_LOG
|
|
<< "ERRORRRRR " << ex.what() << "" << BOOST_THREAD_END_LOG;
|
|
return 1;
|
|
}
|
|
catch (...)
|
|
{
|
|
BOOST_THREAD_LOG
|
|
<< " ERRORRRRR exception thrown" << BOOST_THREAD_END_LOG;
|
|
return 2;
|
|
}
|
|
}
|
|
{
|
|
try
|
|
{
|
|
{
|
|
BOOST_THREAD_LOG << BOOST_THREAD_END_LOG;
|
|
boost::future<boost::csbl::tuple<> > all0 = boost::when_any();
|
|
BOOST_THREAD_LOG << BOOST_THREAD_END_LOG;
|
|
}
|
|
{
|
|
BOOST_THREAD_LOG << BOOST_THREAD_END_LOG;
|
|
boost::future<int> f1 = boost::async(boost::launch::async, &p1);
|
|
boost::future<boost::csbl::tuple<boost::future<int> > > all = boost::when_any(boost::move(f1));
|
|
boost::csbl::tuple<boost::future<int> > res = all.get();
|
|
BOOST_THREAD_LOG
|
|
<< boost::csbl::get<0>(res).get() <<" " << BOOST_THREAD_END_LOG;
|
|
}
|
|
#if defined(BOOST_THREAD_PROVIDES_VARIADIC_THREAD)
|
|
{
|
|
BOOST_THREAD_LOG << BOOST_THREAD_END_LOG;
|
|
boost::future<int> f1 = boost::async(boost::launch::deferred, &p1);
|
|
boost::future<boost::csbl::tuple<boost::future<int> > > all = boost::when_any(boost::move(f1));
|
|
boost::csbl::tuple<boost::future<int> > res = all.get();
|
|
BOOST_THREAD_LOG
|
|
<< boost::csbl::get<0>(res).get() <<" " << BOOST_THREAD_END_LOG;
|
|
}
|
|
#endif
|
|
{
|
|
BOOST_THREAD_LOG << BOOST_THREAD_END_LOG;
|
|
boost::future<int> f1 = boost::async(boost::launch::async, &p1);
|
|
boost::future<int> f2 = boost::async(boost::launch::async, &p1b);
|
|
boost::future<boost::csbl::tuple<boost::future<int>,boost::future<int> > > all = boost::when_any(boost::move(f1), boost::move(f2));
|
|
boost::csbl::tuple<boost::future<int>,boost::future<int> > res = all.get();
|
|
BOOST_THREAD_LOG
|
|
<< boost::csbl::get<0>(res).get() <<" " << BOOST_THREAD_END_LOG;
|
|
BOOST_THREAD_LOG
|
|
<< boost::csbl::get<1>(res).get() <<" " << BOOST_THREAD_END_LOG;
|
|
}
|
|
{
|
|
BOOST_THREAD_LOG << BOOST_THREAD_END_LOG;
|
|
boost::future<int> f1 = boost::make_ready_future(1);
|
|
boost::future<int> f2 = boost::async(boost::launch::async, &p1b);
|
|
boost::future<boost::csbl::tuple<boost::future<int>,boost::future<int> > > all = boost::when_any(boost::move(f1), boost::move(f2));
|
|
boost::csbl::tuple<boost::future<int>,boost::future<int> > res = all.get();
|
|
BOOST_THREAD_LOG
|
|
<< boost::csbl::get<0>(res).get() <<" " << BOOST_THREAD_END_LOG;
|
|
BOOST_THREAD_LOG
|
|
<< boost::csbl::get<1>(res).get() <<" " << BOOST_THREAD_END_LOG;
|
|
}
|
|
{
|
|
BOOST_THREAD_LOG << BOOST_THREAD_END_LOG;
|
|
boost::future<std::string> f1 = boost::make_ready_future(std::string("aaaa"));
|
|
boost::future<int> f2 = boost::async(boost::launch::async, &p1b);
|
|
boost::future<boost::csbl::tuple<boost::future<std::string>,boost::future<int> > > all = boost::when_any(boost::move(f1), boost::move(f2));
|
|
boost::csbl::tuple<boost::future<std::string>,boost::future<int> > res = all.get();
|
|
BOOST_THREAD_LOG
|
|
<< boost::csbl::get<0>(res).get() <<" " << BOOST_THREAD_END_LOG;
|
|
BOOST_THREAD_LOG
|
|
<< boost::csbl::get<1>(res).get() <<" " << BOOST_THREAD_END_LOG;
|
|
}
|
|
{
|
|
BOOST_THREAD_LOG << BOOST_THREAD_END_LOG;
|
|
boost::future<int> f2 = boost::make_ready_future(1);
|
|
boost::future<int> f1 = boost::async(boost::launch::async, &p1b);
|
|
boost::future<boost::csbl::tuple<boost::future<int>,boost::future<int> > > all = boost::when_any(boost::move(f1), boost::move(f2));
|
|
boost::csbl::tuple<boost::future<int>,boost::future<int> > res = all.get();
|
|
BOOST_THREAD_LOG
|
|
<< boost::csbl::get<0>(res).get() <<" " << BOOST_THREAD_END_LOG;
|
|
BOOST_THREAD_LOG
|
|
<< boost::csbl::get<1>(res).get() <<" " << BOOST_THREAD_END_LOG;
|
|
}
|
|
#if defined(BOOST_THREAD_PROVIDES_VARIADIC_THREAD)
|
|
{
|
|
BOOST_THREAD_LOG << BOOST_THREAD_END_LOG;
|
|
boost::future<int> f1 = boost::async(boost::launch::deferred, &p1);
|
|
boost::future<int> f2 = boost::async(boost::launch::async, &p1b);
|
|
boost::future<boost::csbl::tuple<boost::future<int>,boost::future<int> > > all = boost::when_any(boost::move(f1), boost::move(f2));
|
|
boost::csbl::tuple<boost::future<int>,boost::future<int> > res = all.get();
|
|
BOOST_THREAD_LOG
|
|
<< boost::csbl::get<0>(res).get() <<" " << BOOST_THREAD_END_LOG;
|
|
BOOST_THREAD_LOG
|
|
<< boost::csbl::get<1>(res).get() <<" " << BOOST_THREAD_END_LOG;
|
|
}
|
|
{
|
|
BOOST_THREAD_LOG << BOOST_THREAD_END_LOG;
|
|
boost::future<int> f1 = boost::async(boost::launch::async, &p1);
|
|
boost::future<int> f2 = boost::async(boost::launch::deferred, &p1b);
|
|
boost::future<boost::csbl::tuple<boost::future<int>,boost::future<int> > > all = boost::when_any(boost::move(f1), boost::move(f2));
|
|
boost::csbl::tuple<boost::future<int>,boost::future<int> > res = all.get();
|
|
BOOST_THREAD_LOG
|
|
<< boost::csbl::get<0>(res).get() <<" " << BOOST_THREAD_END_LOG;
|
|
BOOST_THREAD_LOG
|
|
<< boost::csbl::get<1>(res).get() <<" " << BOOST_THREAD_END_LOG;
|
|
}
|
|
#endif
|
|
{
|
|
BOOST_THREAD_LOG << BOOST_THREAD_END_LOG;
|
|
boost::csbl::vector<boost::future<int> > v;
|
|
BOOST_THREAD_LOG << BOOST_THREAD_END_LOG;
|
|
v.push_back(boost::async(boost::launch::async, &p1));
|
|
BOOST_THREAD_LOG << BOOST_THREAD_END_LOG;
|
|
v.push_back(boost::async(boost::launch::async, &p1b));
|
|
BOOST_THREAD_LOG << BOOST_THREAD_END_LOG;
|
|
boost::future<boost::csbl::vector<boost::future<int> > > all = boost::when_any(v.begin(), v.end());
|
|
BOOST_THREAD_LOG << BOOST_THREAD_END_LOG;
|
|
boost::csbl::vector<boost::future<int> > res = all.get();
|
|
BOOST_THREAD_LOG
|
|
<< res[0].get() <<" " << BOOST_THREAD_END_LOG;
|
|
BOOST_THREAD_LOG
|
|
<< res[1].get() <<" " << BOOST_THREAD_END_LOG;
|
|
}
|
|
}
|
|
catch (std::exception& ex)
|
|
{
|
|
BOOST_THREAD_LOG
|
|
<< "ERRORRRRR " << ex.what() << "" << BOOST_THREAD_END_LOG;
|
|
return 1;
|
|
}
|
|
catch (...)
|
|
{
|
|
BOOST_THREAD_LOG
|
|
<< " ERRORRRRR exception thrown" << BOOST_THREAD_END_LOG;
|
|
return 2;
|
|
}
|
|
}
|
|
BOOST_THREAD_LOG
|
|
<< "MAIN>" << BOOST_THREAD_END_LOG;
|
|
return 0;
|
|
}
|
|
#else
|
|
#include <boost/thread/csbl/vector.hpp>
|
|
using namespace boost;
|
|
|
|
void f( boost::csbl::vector<future<int> > &//vec
|
|
, BOOST_THREAD_RV_REF(future<int>) //f
|
|
) {
|
|
}
|
|
int main()
|
|
{
|
|
boost::csbl::vector<future<int> > vec;
|
|
f(vec, make_ready_future(0));
|
|
return 0;
|
|
}
|
|
#endif
|