ceph/src/boost/libs/thread/test/sync/futures/when_any/iterators_pass.cpp

   1 //===----------------------------------------------------------------------===//
   2 //
   3 //                     The LLVM Compiler Infrastructure
   4 //
   5 // This file is dual licensed under the MIT and the University of Illinois Open
   6 // Source Licenses. See LICENSE.TXT for details.
   7 //
   8 //===----------------------------------------------------------------------===//
   9
  10 // Copyright (C) 2014 Vicente J. Botet Escriba
  11 //
  12 //  Distributed under the Boost Software License, Version 1.0. (See accompanying
  13 //  file LICENSE_1_0.txt or copy at http://www.boost.org/LICENSE_1_0.txt)
  14
  15 // <boost/thread/future.hpp>
  16
  17 //  template< typename InputIterator>
  18 //  future<vector<typename InputIterator::value_type>  >
  19 //    when_any(InputIterator first, InputIterator last)
  20
  21 #include <boost/config.hpp>
  22
  23 #if ! defined  BOOST_NO_CXX11_DECLTYPE
  24 #define BOOST_RESULT_OF_USE_DECLTYPE
  25 #endif
  26
  27
  28 #define BOOST_THREAD_VERSION 4
  29
  30 #include <boost/thread/future.hpp>
  31 #include <boost/detail/lightweight_test.hpp>
  32 #include <stdexcept>
  33
  34 #ifdef BOOST_MSVC
  35 #pragma warning(disable: 4127) // conditional expression is constant
  36 #endif
  37
  38 int p1()
  39 {
  40   return 123;
  41 }
  42
  43 int thr()
  44 {
  45   throw std::logic_error("123");
  46 }
  47 int p2()
  48 {
  49   boost::this_thread::sleep_for(boost::chrono::milliseconds(200));
  50   return 321;
  51 }
  52
  53 int main()
  54 {
  55 #if defined BOOST_THREAD_PROVIDES_FUTURE_WHEN_ALL_WHEN_ANY
  56   if (0) // todo not yet implemented
  57   { // invalid future copy-constructible
  58     boost::csbl::vector<boost::future<int> > v;
  59     boost::future<int> f1;
  60     v.push_back(boost::move(f1));
  61     v.push_back(boost::make_ready_future(321));
  62     BOOST_TEST(! v[0].valid());
  63     BOOST_TEST(v[1].valid());
  64
  65     boost::future<boost::csbl::vector<boost::future<int> > > all = boost::when_any(v.begin(), v.end());
  66     BOOST_TEST(! v[0].valid());
  67     BOOST_TEST(! v[1].valid());
  68     BOOST_TEST(all.valid());
  69     boost::csbl::vector<boost::future<int> > res = all.get();
  70     BOOST_TEST(res.size() == 2);
  71     BOOST_TEST(res[1].valid());
  72     BOOST_TEST(res[1].is_ready());
  73     // has exception
  74     //BOOST_TEST(res[0].get() == 123);
  75     BOOST_TEST(res[1].valid());
  76     BOOST_TEST(res[1].is_ready());
  77     BOOST_TEST(res[1].get() == 321);
  78   }
  79   { // is_ready future copy-constructible
  80     boost::future<int> f1 = boost::make_ready_future(123);
  81     boost::future<int> f2 = boost::make_ready_future(321);
  82     boost::csbl::vector<boost::future<int> > v;
  83     v.push_back(boost::move(f1));
  84     v.push_back(boost::move(f2));
  85     BOOST_TEST(v[0].valid());
  86     BOOST_TEST(v[0].is_ready());
  87     BOOST_TEST(v[1].valid());
  88     BOOST_TEST(v[1].is_ready());
  89     boost::future<boost::csbl::vector<boost::future<int> > > all = boost::when_any(v.begin(), v.end());
  90     BOOST_TEST(! v[0].valid());
  91     BOOST_TEST(! v[1].valid());
  92     BOOST_TEST(all.valid());
  93     if (0) // todo FAILS not yet implemented
  94     BOOST_TEST(all.is_ready());
  95     boost::csbl::vector<boost::future<int> > res = all.get();
  96     BOOST_TEST(res[0].valid());
  97     BOOST_TEST(res[0].is_ready());
  98     BOOST_TEST(res[0].get() == 123);
  99     BOOST_TEST(res[1].valid());
 100     BOOST_TEST(res[1].is_ready());
 101     BOOST_TEST(res[1].get() == 321);
 102   }
 103   { // is_ready shared_future copy-constructible
 104     boost::shared_future<int> f1 = boost::make_ready_future(123).share();
 105     boost::shared_future<int> f2 = boost::make_ready_future(321).share();
 106     boost::csbl::vector<boost::shared_future<int> > v;
 107     v.push_back(f1);
 108     v.push_back(f2);
 109     BOOST_TEST(v[0].valid());
 110     BOOST_TEST(v[0].is_ready());
 111     BOOST_TEST(v[1].valid());
 112     BOOST_TEST(v[1].is_ready());
 113     boost::future<boost::csbl::vector<boost::shared_future<int> > > all = boost::when_any(v.begin(), v.end());
 114     if (0) // fixme
 115     BOOST_TEST(v[0].valid());
 116     if (0) // fixme
 117     BOOST_TEST(v[1].valid());
 118     BOOST_TEST(all.valid());
 119     if (0) // todo FAILS not yet implemented
 120     BOOST_TEST(all.is_ready());
 121     boost::csbl::vector<boost::shared_future<int> > res = all.get();
 122     BOOST_TEST(res[0].valid());
 123     BOOST_TEST(res[0].is_ready());
 124     BOOST_TEST(res[0].get() == 123);
 125     BOOST_TEST(res[1].valid());
 126     BOOST_TEST(res[1].is_ready());
 127     BOOST_TEST(res[1].get() == 321);
 128   }
 129   { // packaged_task future copy-constructible
 130     boost::packaged_task<int()> pt1(&p1);
 131     boost::future<int> f1 = pt1.get_future();
 132     BOOST_TEST(f1.valid());
 133     boost::packaged_task<int()> pt2(&p2);
 134     boost::future<int> f2 = pt2.get_future();
 135     BOOST_TEST(f2.valid());
 136     boost::csbl::vector<boost::future<int> > v;
 137     v.push_back(boost::move(f1));
 138     v.push_back(boost::move(f2));
 139     BOOST_TEST(v[0].valid());
 140     BOOST_TEST(v[1].valid());
 141     boost::future<boost::csbl::vector<boost::future<int> > > all = boost::when_any(v.begin(), v.end());
 142     BOOST_TEST(! v[0].valid());
 143     BOOST_TEST(! v[1].valid());
 144     BOOST_TEST(all.valid());
 145     pt1();
 146     pt2();
 147     boost::csbl::vector<boost::future<int> > res = all.get();
 148     BOOST_TEST(res[0].valid());
 149     BOOST_TEST(res[0].is_ready());
 150     BOOST_TEST(res[0].get() == 123);
 151     BOOST_TEST(res[1].valid());
 152     BOOST_TEST(res[1].is_ready());
 153     BOOST_TEST(res[1].get() == 321);
 154   }
 155   { // packaged_task future copy-constructible
 156     boost::packaged_task<int()> pt1(&thr);
 157     boost::future<int> f1 = pt1.get_future();
 158     BOOST_TEST(f1.valid());
 159     boost::packaged_task<int()> pt2(&p2);
 160     boost::future<int> f2 = pt2.get_future();
 161     BOOST_TEST(f2.valid());
 162     boost::csbl::vector<boost::future<int> > v;
 163     v.push_back(boost::move(f1));
 164     v.push_back(boost::move(f2));
 165     BOOST_TEST(v[0].valid());
 166     BOOST_TEST(v[1].valid());
 167     boost::future<boost::csbl::vector<boost::future<int> > > all = boost::when_any(v.begin(), v.end());
 168     BOOST_TEST(! v[0].valid());
 169     BOOST_TEST(! v[1].valid());
 170     BOOST_TEST(all.valid());
 171     pt1();
 172     pt2();
 173     boost::csbl::vector<boost::future<int> > res = all.get();
 174     BOOST_TEST(res[0].valid());
 175     BOOST_TEST(res[0].is_ready());
 176     try {
 177       res[0].get();
 178       BOOST_TEST(false);
 179     } catch (std::logic_error& ex) {
 180       BOOST_TEST(ex.what() == std::string("123"));
 181     } catch (...) {
 182       BOOST_TEST(false);
 183     }
 184     BOOST_TEST(res[1].valid());
 185     BOOST_TEST(res[1].is_ready());
 186     BOOST_TEST(res[1].get() == 321);
 187   }
 188   { // packaged_task shared_future copy-constructible
 189     boost::packaged_task<int()> pt1(&p1);
 190     boost::shared_future<int> f1 = pt1.get_future().share();
 191     BOOST_TEST(f1.valid());
 192     boost::packaged_task<int()> pt2(&p2);
 193     boost::shared_future<int> f2 = pt2.get_future().share();
 194     BOOST_TEST(f2.valid());
 195     boost::csbl::vector<boost::shared_future<int> > v;
 196     v.push_back(f1);
 197     v.push_back(f2);
 198     BOOST_TEST(v[0].valid());
 199     BOOST_TEST(v[1].valid());
 200     boost::future<boost::csbl::vector<boost::shared_future<int> > > all = boost::when_any(v.begin(), v.end());
 201     if (0) // fixme
 202     BOOST_TEST(v[0].valid());
 203     if (0) // fixme
 204     BOOST_TEST(v[1].valid());
 205     BOOST_TEST(all.valid());
 206     BOOST_TEST(! all.is_ready());
 207     pt1();
 208     BOOST_TEST(! all.is_ready());
 209     pt2();
 210     boost::this_thread::sleep_for(boost::chrono::milliseconds(300));
 211     BOOST_TEST(all.is_ready());
 212     boost::csbl::vector<boost::shared_future<int> > res = all.get();
 213     BOOST_TEST(res[0].valid());
 214     BOOST_TEST(res[0].is_ready());
 215     BOOST_TEST(res[0].get() == 123);
 216     BOOST_TEST(res[1].valid());
 217     BOOST_TEST(res[1].is_ready());
 218     BOOST_TEST(res[1].get() == 321);
 219   }
 220   { // async future copy-constructible
 221     boost::future<int> f1 = boost::async(boost::launch::async, &p1);
 222     BOOST_TEST(f1.valid());
 223     boost::future<int> f2 = boost::async(boost::launch::async, &p2);
 224     BOOST_TEST(f2.valid());
 225     boost::csbl::vector<boost::future<int> > v;
 226     v.push_back(boost::move(f1));
 227     v.push_back(boost::move(f2));
 228     BOOST_TEST(v[0].valid());
 229     BOOST_TEST(v[1].valid());
 230     boost::future<boost::csbl::vector<boost::future<int> > > all = boost::when_any(v.begin(), v.end());
 231     BOOST_TEST(! v[0].valid());
 232     BOOST_TEST(! v[1].valid());
 233     BOOST_TEST(all.valid());
 234     boost::csbl::vector<boost::future<int> > res = all.get();
 235     BOOST_TEST(res[0].valid());
 236     BOOST_TEST(res[0].is_ready());
 237     BOOST_TEST(res[0].get() == 123);
 238     BOOST_TEST(res[1].valid());
 239     BOOST_TEST(! res[1].is_ready());
 240     BOOST_TEST(res[1].get() == 321);
 241   }
 242   { // async shared_future copy-constructible
 243     boost::shared_future<int> f1 = boost::async(boost::launch::async, &p1).share();
 244     BOOST_TEST(f1.valid());
 245     boost::shared_future<int> f2 = boost::async(boost::launch::async, &p2).share();
 246     BOOST_TEST(f2.valid());
 247     boost::csbl::vector<boost::shared_future<int> > v;
 248     v.push_back(f1);
 249     v.push_back(f2);
 250     BOOST_TEST(v[0].valid());
 251     BOOST_TEST(v[1].valid());
 252     boost::future<boost::csbl::vector<boost::shared_future<int> > > all = boost::when_any(v.begin(), v.end());
 253     if (0) // fixme
 254     BOOST_TEST(v[0].valid());
 255     if (0) // fixme
 256     BOOST_TEST(v[1].valid());
 257     BOOST_TEST(all.valid());
 258     boost::csbl::vector<boost::shared_future<int> > res = all.get();
 259     BOOST_TEST(res[0].valid());
 260     BOOST_TEST(res[0].is_ready());
 261     BOOST_TEST(res[0].get() == 123);
 262     BOOST_TEST(res[1].valid());
 263     BOOST_TEST(! res[1].is_ready());
 264     BOOST_TEST(res[1].get() == 321);
 265   }
 266   { // async future copy-constructible
 267     boost::future<int> f1 = boost::async(boost::launch::async, &p1);
 268     BOOST_TEST(f1.valid());
 269     boost::future<int> f2 = boost::make_ready_future(321);
 270     BOOST_TEST(f2.valid());
 271     BOOST_TEST(f2.is_ready());
 272     boost::csbl::vector<boost::future<int> > v;
 273     v.push_back(boost::move(f1));
 274     v.push_back(boost::move(f2));
 275     BOOST_TEST(v[0].valid());
 276     BOOST_TEST(v[1].valid());
 277     boost::future<boost::csbl::vector<boost::future<int> > > all = boost::when_any(v.begin(), v.end());
 278     BOOST_TEST(! v[0].valid());
 279     BOOST_TEST(! v[1].valid());
 280     BOOST_TEST(all.valid());
 281     boost::csbl::vector<boost::future<int> > res = all.get();
 282     BOOST_TEST(res[0].valid());
 283     if (0) // fixme
 284     BOOST_TEST(! res[0].is_ready());
 285     BOOST_TEST(res[0].get() == 123);
 286     BOOST_TEST(res[1].valid());
 287     BOOST_TEST(res[1].is_ready());
 288     BOOST_TEST(res[1].get() == 321);
 289   }
 290 #if defined BOOST_THREAD_PROVIDES_VARIADIC_THREAD
 291   // fixme darwin-4.8.0_11 terminate called without an active exception
 292   { // deferred future copy-constructible
 293     boost::future<int> f1 = boost::async(boost::launch::deferred, &p1);
 294     boost::future<int> f2 = boost::async(boost::launch::deferred, &p2);
 295     boost::csbl::vector<boost::future<int> > v;
 296     v.push_back(boost::move(f1));
 297     v.push_back(boost::move(f2));
 298     BOOST_TEST(v[0].valid());
 299     BOOST_TEST(v[1].valid());
 300     boost::future<boost::csbl::vector<boost::future<int> > > all = boost::when_any(v.begin(), v.end());
 301     BOOST_TEST(! v[0].valid());
 302     BOOST_TEST(! v[1].valid());
 303     BOOST_TEST(all.valid());
 304     boost::csbl::vector<boost::future<int> > res = all.get();
 305     BOOST_TEST(res[0].valid());
 306     BOOST_TEST(res[0].is_ready());
 307     BOOST_TEST(res[0].get() == 123);
 308     BOOST_TEST(res[1].valid());
 309     BOOST_TEST(! res[1].is_ready());
 310     BOOST_TEST(res[1].get() == 321);
 311   }
 312   // fixme darwin-4.8.0_11 terminate called without an active exception
 313   { // deferred shared_future copy-constructible
 314     boost::shared_future<int> f1 = boost::async(boost::launch::deferred, &p1).share();
 315     boost::shared_future<int> f2 = boost::async(boost::launch::deferred, &p2).share();
 316     boost::csbl::vector<boost::shared_future<int> > v;
 317     v.push_back(f1);
 318     v.push_back(f2);
 319     BOOST_TEST(v[0].valid());
 320     BOOST_TEST(v[1].valid());
 321     boost::future<boost::csbl::vector<boost::shared_future<int> > > all = boost::when_any(v.begin(), v.end());
 322     if (0) // fixme
 323     BOOST_TEST(v[0].valid());
 324     if (0) // fixme
 325     BOOST_TEST(v[1].valid());
 326     BOOST_TEST(all.valid());
 327     boost::csbl::vector<boost::shared_future<int> > res = all.get();
 328     BOOST_TEST(res[0].valid());
 329     BOOST_TEST(res[0].is_ready());
 330     BOOST_TEST(res[0].get() == 123);
 331     BOOST_TEST(res[1].valid());
 332     BOOST_TEST(! res[1].is_ready());
 333     BOOST_TEST(res[1].get() == 321);
 334   }
 335 #endif
 336 #if ! defined BOOST_NO_CXX11_LAMBDAS
 337     { // async futures copy-constructible then()
 338       boost::future<int> f1 = boost::async(boost::launch::async, &p1);
 339       BOOST_TEST(f1.valid());
 340       boost::future<int> f2 = boost::async(boost::launch::async, &p2);
 341       BOOST_TEST(f2.valid());
 342       boost::csbl::vector<boost::future<int> > v;
 343       v.push_back(boost::move(f1));
 344       v.push_back(boost::move(f2));
 345       BOOST_TEST(v[0].valid());
 346       BOOST_TEST(v[1].valid());
 347       boost::future<boost::csbl::vector<boost::future<int> > > all = boost::when_any(v.begin(), v.end());
 348       BOOST_TEST(! v[0].valid());
 349       BOOST_TEST(! v[1].valid());
 350       BOOST_TEST(all.valid());
 351       boost::future<int> sum = all.then([](boost::future<boost::csbl::vector<boost::future<int> > > f)
 352       {
 353         boost::csbl::vector<boost::future<int> > v = f.get();
 354         return v[0].get() + v[1].get();
 355       });
 356       BOOST_TEST(sum.valid());
 357       BOOST_TEST(sum.get() == 444);
 358     }
 359 #endif
 360 #endif
 361
 362   return boost::report_errors();
 363 }
 364