1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798 |
- // Copyright Oliver Kowalke 2013.
- // Distributed under the Boost Software License, Version 1.0.
- // (See accompanying file LICENSE_1_0.txt or copy at
- // http://www.boost.org/LICENSE_1_0.txt)
- #include <cstdlib>
- #include <functional>
- #include <iostream>
- #include <stdexcept>
- #include <boost/assert.hpp>
- #include <boost/fiber/all.hpp>
- int value1 = 0;
- int value2 = 0;
- inline
- void fn1( boost::fibers::barrier & b)
- {
- boost::fibers::fiber::id id = boost::this_fiber::get_id();
- std::cout << "fiber " << id << ": fn1 entered" << std::endl;
- ++value1;
- std::cout << "fiber " << id << ": incremented value1: " << value1 << std::endl;
- boost::this_fiber::yield();
- std::cout << "fiber " << id << ": waits for barrier" << std::endl;
- b.wait();
- std::cout << "fiber " << id << ": passed barrier" << std::endl;
- ++value1;
- std::cout << "fiber " << id << ": incremented value1: " << value1 << std::endl;
- boost::this_fiber::yield();
- ++value1;
- std::cout << "fiber " << id << ": incremented value1: " << value1 << std::endl;
- boost::this_fiber::yield();
- ++value1;
- std::cout << "fiber " << id << ": incremented value1: " << value1 << std::endl;
- boost::this_fiber::yield();
- std::cout << "fiber " << id << ": fn1 returns" << std::endl;
- }
- inline
- void fn2( boost::fibers::barrier & b)
- {
- boost::fibers::fiber::id id = boost::this_fiber::get_id();
- std::cout << "fiber " << id << ": fn2 entered" << std::endl;
- ++value2;
- std::cout << "fiber " << id << ": incremented value2: " << value2 << std::endl;
- boost::this_fiber::yield();
- ++value2;
- std::cout << "fiber " << id << ": incremented value2: " << value2 << std::endl;
- boost::this_fiber::yield();
- ++value2;
- std::cout << "fiber " << id << ": incremented value2: " << value2 << std::endl;
- boost::this_fiber::yield();
- std::cout << "fiber " << id << ": waits for barrier" << std::endl;
- b.wait();
- std::cout << "fiber " << id << ": passed barrier" << std::endl;
- ++value2;
- std::cout << "fiber " << id << ": incremented value2: " << value2 << std::endl;
- boost::this_fiber::yield();
- std::cout << "fiber " << id << ": fn2 returns" << std::endl;
- }
- int main()
- {
- try
- {
- boost::fibers::barrier fb( 2);
- boost::fibers::fiber f1( & fn1, std::ref( fb) );
- boost::fibers::fiber f2( & fn2, std::ref( fb) );
- f1.join();
- f2.join();
- std::cout << "done." << std::endl;
- return EXIT_SUCCESS;
- }
- catch ( std::exception const& e)
- { std::cerr << "exception: " << e.what() << std::endl; }
- catch (...)
- { std::cerr << "unhandled exception" << std::endl; }
- return EXIT_FAILURE;
- }
|