ceph/src/boost/libs/thread/test/test_11611.cpp

   1 // Copyright (C) 2014 Vicente Botet
   2 //
   3 //  Distributed under the Boost Software License, Version 1.0. (See accompanying
   4 //  file LICENSE_1_0.txt or copy at http://www.boost.org/LICENSE_1_0.txt)
   5
   6 //#define BOOST_THREAD_VERSION 4
   7
   8 #include <iostream>
   9 //#include <thread>
  10
  11 #define BOOST_THREAD_PROVIDES_FUTURE
  12 #define BOOST_THREAD_PROVIDES_EXECUTORS
  13 #define BOOST_THREAD_PROVIDES_FUTURE_CONTINUATION
  14 #include <boost/thread/executors/loop_executor.hpp>
  15 #include <boost/thread/executors/serial_executor_cont.hpp>
  16 #include <boost/thread/executors/serial_executor.hpp>
  17 #include <boost/thread/thread.hpp>
  18
  19 using namespace std;
  20
  21 int main()
  22 {
  23    boost::loop_executor ex;
  24
  25    //thread t([&ex]()
  26    boost::thread t([&ex]()
  27    {
  28       ex.loop();
  29    });
  30
  31    {
  32      //boost::serial_executor_cont serial(ex);
  33      boost::serial_executor serial(ex);
  34
  35       for (size_t i = 0; i < 100000; i++)
  36          serial.submit([i] {
  37              //std::cout << i << ".";
  38          });
  39
  40       serial.close();
  41    }
  42
  43    ex.close();
  44
  45    t.join();
  46    std::cout << "end" << std::endl;
  47    return 0;
  48 }