mirror of
https://github.com/boostorg/fiber.git
synced 2026-02-20 02:32:19 +00:00
b53e167a68
- buffered_channel: MPMC with lock-free guarantees - unbuffered_channel: rendezvous point
47 lines
1.2 KiB
C++
47 lines
1.2 KiB
C++
#include <cstdlib>
|
|
#include <iostream>
|
|
#include <stdexcept>
|
|
#include <string>
|
|
|
|
#include <boost/fiber/all.hpp>
|
|
|
|
typedef boost::fibers::buffered_channel< std::string > channel_t;
|
|
|
|
inline
|
|
void foo( channel_t & chan1, channel_t & chan2, std::string const& msg)
|
|
{
|
|
boost::fibers::fiber::id id( boost::this_fiber::get_id() );
|
|
chan1.push( msg);
|
|
std::string value{ chan2.value_pop() };
|
|
std::cout << "fiber " << id << ": " << value << " received" << std::endl;
|
|
chan1.push( msg);
|
|
value = chan2.value_pop();
|
|
std::cout << "fiber " << id << ": " << value << " received" << std::endl;
|
|
chan1.push( msg);
|
|
value = chan2.value_pop();
|
|
std::cout << "fiber " << id << ": " << value << " received" << std::endl;
|
|
}
|
|
|
|
int main()
|
|
{
|
|
try
|
|
{
|
|
channel_t chan1{ 2 }, chan2{ 2 };
|
|
|
|
boost::fibers::fiber f1( & foo, std::ref( chan1), std::ref( chan2), std::string("ping") );
|
|
boost::fibers::fiber f2( & foo, std::ref( chan2), std::ref( chan1), std::string("pong") );
|
|
|
|
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;
|
|
}
|