redisgate Gent boost_fiber bfiber_0500

Boost.Fiber Synchronization Buffered Channel

Synchronization Buffered Channel

Boost.Fiber는 비동기 메시지 전달을 통해 파이버(동일하거나 다른 스레드에서 실행)를 동기화하는 데 적합한 경계(bounded)가 있고 버퍼링된(buffered) 채널(MPMC 대기열)을 제공합니다. typedef boost::fibers::buffered_channel< int > channel_t; void send( channel_t & chan) { for ( int i = 0; i < 5; ++i) { chan.push( i); } chan.close(); } void recv( channel_t & chan) { int i; while ( boost::fibers::channel_op_status::success == chan.pop(i) ) { std::cout << "received " << i << std::endl; } } channel_t chan{ 2 }; boost::fibers::fiber f1( std::bind( send, std::ref( chan) ) ); boost::fibers::fiber f2( std::bind( recv, std::ref( chan) ) ); f1.join(); f2.join();

📦 Template buffered_channel<>