redisgate Gent boost_fiber bfiber_0500

Boost.Fiber Synchronization Unbuffered Channel

Synchronization Unbuffered Channel

Boost.Fiber는 동기 메시지 전달을 통해 파이버(동일하거나 다른 스레드에서 실행)를 동기화하는 데 적합한 unbuffered_channel 템플릿을 제공합니다.   값을 소비하기를 기다리는 파이버는 값이 생성될 때까지 차단됩니다.   파이버가 버퍼링되지 않은(unbuffered) 채널을 통해 값을 전송하려고 시도하고 값을 수신하기 위해 대기 중인 파이버가 없는 경우, 채널은 전송 파이버를 차단합니다.

버퍼링되지 않은 채널은 랑데부 포인트 역할을 합니다.
typedef boost::fibers::unbuffered_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{ 1 }; // 아래 chatgpt 설명 참조 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 unbuffered_channel<>