{

// std::cout << BOOST_CONTEXTOF << std::endl;

//boost::this_thread::sleep_for(boost::chrono::milliseconds(200));

{

// std::cout << BOOST_CONTEXTOF << std::endl;

//boost::this_thread::sleep_for(boost::chrono::seconds(10));

{

std::cout << BOOST_CONTEXTOF << std::endl;

boost::this_thread::sleep_for(boost::chrono::seconds(1));

std::cout << BOOST_CONTEXTOF << std::endl;

return 1;

{

// std::cout << BOOST_CONTEXTOF << std::endl;

boost::this_thread::sleep_for(boost::chrono::seconds(2));

return i + 1;

{

for (int i = 0; i < 3; ++i) {

tp.submit(&p2);

}

for (int i = 0; i < 3; ++i) {

tp.submit(&p1);

}

{

std::cout << BOOST_CONTEXTOF << std::endl;

{

try

{

{

boost::executor_adaptor < boost::basic_thread_pool > ea(4);

std::cout << BOOST_CONTEXTOF << std::endl;

submit_some( ea);

std::cout << BOOST_CONTEXTOF << std::endl;

#if 1

// fixme

// ERROR= tr1::bad_weak_ptr

{

boost::future<int> t1 = boost::async(ea, &f1);

boost::future<int> t2 = boost::async(ea, &f1);

std::cout << BOOST_CONTEXTOF << " t1= " << t1.get() << std::endl;

std::cout << BOOST_CONTEXTOF << " t2= " << t2.get() << std::endl;

}

std::cout << BOOST_CONTEXTOF << std::endl;

submit_some(ea);

std::cout << BOOST_CONTEXTOF << std::endl;

{

boost::basic_thread_pool ea3(1);

std::cout << BOOST_CONTEXTOF << std::endl;

boost::future<int> t1 = boost::async(ea3, &f1);

std::cout << BOOST_CONTEXTOF << std::endl;

boost::future<int> t2 = boost::async(ea3, &f1);

std::cout << BOOST_CONTEXTOF << std::endl;

//boost::future<int> t2 = boost::async(ea3, f2, 1); // todo this doesn't compiles yet on C++11

//boost::future<int> t2 = boost::async(ea3, boost::bind(f2, 1)); // todo this doesn't compiles yet on C++98

std::cout << BOOST_CONTEXTOF << " t1= " << t1.get() << std::endl;

std::cout << BOOST_CONTEXTOF << " t2= " << t2.get() << std::endl;

}

#endif

std::cout << BOOST_CONTEXTOF << std::endl;

submit_some(ea);

std::cout << BOOST_CONTEXTOF << std::endl;

}

std::cout << BOOST_CONTEXTOF << std::endl;

{

boost::executor_adaptor < boost::loop_executor > ea2;

submit_some( ea2);

ea2.underlying_executor().run_queued_closures();

}

#if ! defined(BOOST_NO_CXX11_RVALUE_REFERENCES)

std::cout << BOOST_CONTEXTOF << std::endl;

{

boost::executor_adaptor < boost::basic_thread_pool > ea1(4);

boost::executor_adaptor < boost::serial_executor > ea2(ea1);

submit_some(ea2);

}

#endif

std::cout << BOOST_CONTEXTOF << std::endl;

{

boost::executor_adaptor < boost::inline_executor > ea1;

submit_some(ea1);

}

std::cout << BOOST_CONTEXTOF << std::endl;

{

boost::executor_adaptor < boost::thread_executor > ea1;

submit_some(ea1);

}

std::cout << BOOST_CONTEXTOF << std::endl;

#if 1

// fixme

// ERROR= tr1::bad_weak_ptr

{

boost::basic_thread_pool ea(4, at_th_entry);

boost::future<int> t1 = boost::async(ea, &f1);

std::cout << BOOST_CONTEXTOF << " t1= " << t1.get() << std::endl;

}

#endif

std::cout << BOOST_CONTEXTOF << std::endl;

{

boost::async(&f1);

}

#if 1

// fixme

// ERROR= tr1::bad_weak_ptr

std::cout << BOOST_CONTEXTOF << std::endl;

{

boost::basic_thread_pool ea(1);

boost::async(ea,&f1);

}

#endif

std::cout << BOOST_CONTEXTOF << std::endl;

boost::this_thread::sleep_for(boost::chrono::milliseconds(200));

std::cout << BOOST_CONTEXTOF << std::endl;

}

catch (std::exception& ex)

{

std::cout << "ERROR= " << ex.what() << "" << std::endl;

return 1;

}

catch (...)

{

std::cout << " ERROR= exception thrown" << std::endl;

return 2;

}

}

// std::cout << BOOST_CONTEXTOF << std::endl;

return 0;

{

return test_executor_adaptor();

#if 0 && defined BOOST_THREAD_PROVIDES_FUTURE_CONTINUATION \

&& defined BOOST_THREAD_PROVIDES_EXECUTORS \

&& ! defined BOOST_NO_CXX11_RVALUE_REFERENCES

boost::basic_thread_pool executor;

// compiles

boost::make_ready_future().then(&p);

// ??

boost::make_ready_future().then(executor, &p);

// doesn't compile

boost::make_ready_future().then(executor, &p);

#endif