65 lines
1.8 KiB
C++
65 lines
1.8 KiB
C++
// Copyright (C) 2014 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)
|
||
|
||
#define BOOST_THREAD_VERSION 4
|
||
|
||
// BoostFutureTest.cpp : Defines the entry point for the console application.
|
||
//
|
||
|
||
#include <iostream>
|
||
|
||
// boost version 1.60.0
|
||
// has the following set.
|
||
#define BOOST_THREAD_VERSION 4
|
||
// #define BOOST_THREAD_PROVIDES_EXECUTORS
|
||
|
||
#include <boost/thread/future.hpp>
|
||
|
||
|
||
int main()
|
||
{
|
||
#if __cplusplus >= 201103L
|
||
|
||
int value = 0;
|
||
int tmpValue = 0;
|
||
boost::promise<void> promise1;
|
||
boost::promise<void> promise2;
|
||
|
||
auto future1 = promise1.get_future();
|
||
|
||
auto waitFuture = future1.then([&tmpValue, &promise2](boost::future<void> future){
|
||
assert(future.is_ready()); // this works correctly and is ready.
|
||
|
||
auto fut = boost::async(boost::launch::async, [&promise2, &tmpValue](){
|
||
boost::this_thread::sleep_for(boost::chrono::seconds(1));
|
||
tmpValue = 1;
|
||
promise2.set_value();
|
||
std::cout << "Step 2 "<< std::endl; // should print 1 but prints 0
|
||
});
|
||
std::cout << "Step 1 "<< std::endl; // should print 1 but prints 0
|
||
|
||
return promise2.get_future();
|
||
//return ;
|
||
}).then([&value, &tmpValue](boost::future<boost::future<void>> future){
|
||
//}).then([&value, &tmpValue](boost::future<void> future){
|
||
// error: no matching function for call to ‘boost::future<boost::future<void> >::then(main()::<lambda(boost::future<void>)>)’
|
||
// as expected
|
||
|
||
assert(future.is_ready()); // this doesn't work correctly and is not ready.
|
||
|
||
|
||
value = tmpValue;
|
||
});
|
||
|
||
|
||
promise1.set_value();
|
||
waitFuture.wait();
|
||
|
||
std::cout << "value = " << value << std::endl; // should print 1 but prints 0
|
||
#endif
|
||
return 0;
|
||
}
|
||
|