// success tested on windows7 x64 vc11 and opensuse13.1 gcc4.8.1 amd64, using boost 1.56.0
// failed on boost 1.55.0
// 348944179@qq.com 
// nousxiong

#define BOOST_ASIO_DISABLE_STD_CHRONO

#include <boost/asio.hpp>
#include <boost/asio/spawn.hpp>
#include <boost/asio/system_timer.hpp>
#include <boost/thread.hpp>
#include <boost/chrono.hpp>
#include <boost/bind.hpp>
#include <boost/ref.hpp>
#include <deque>
#include <iostream>

void echo(boost::asio::yield_context yld, boost::asio::io_service& ios)
{
  boost::asio::system_timer tmr(ios);
  tmr.expires_from_now(boost::chrono::seconds(30));
  tmr.async_wait(yld);
}

int main()
{
  try
  {
    std::cout << "begin\n";
    std::size_t thread_num = 10;
    boost::asio::io_service ios;
    std::deque<boost::asio::strand> strand_list;
    for (std::size_t i=0; i<thread_num; ++i)
    {
      // note: gcc must set -std=c++11
      strand_list.emplace_back(boost::ref(ios));
    }
    boost::thread_group thrs;

    for (std::size_t i=0; i<500000; ++i)
    {
      boost::asio::spawn(
        strand_list[i % thread_num],
        boost::bind(
          &echo, _1, boost::ref(ios)
          ),
          boost::coroutines::attributes(
            boost::coroutines::stack_traits::minimum_size()
            )
        );
    }

    for (std::size_t i=0; i<thread_num; ++i)
    {
      thrs.create_thread(boost::bind(&boost::asio::io_service::run, &ios));
    }
    thrs.join_all();

    std::cout << "end\n";
  }
  catch (std::exception& ex)
  {
    std::cerr << ex.what() << std::endl;
  }
  return 0;
}