boost::shared_ptr<boost::generic_executor_ref> current_executor_ptr;

template <class Executor>

void set_current_executor(Executor& ex)

{

current_executor_ptr = boost::make_shared<boost::generic_executor_ref>(ex);

}

boost::generic_executor_ref current_executor()

{

if (current_executor_ptr)

return *current_executor_ptr;

else

throw "";

}

{

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

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

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

{

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

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

current_executor().submit(&p2);

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

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

{

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

boost::basic_thread_pool tp(4,

// at_thread_entry

[](boost::basic_thread_pool& pool)

{

current_executor_state.set_current_executor(pool);

}

);

tp.submit(&p1);

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

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

return 1;