redisgate Gent boost_fiber bfiber_0800

Boost.Fiber Integrating Fibers with Asynchronous Callbacks - Data or Exception

Integrating Fibers with Asynchronous Callbacks - Data or Exception

비동기 콜백과 파이버 통합 - 데이터 또는 예외

그러나 데이터를 얻는 함수에 대한 보다 자연스러운 API는 성공 시 데이터만 반환하고 오류 시 예외를 발생시키는 것입니다.
위의 write()와 마찬가지로 read_ec() 측면에서 read() 래퍼를 코딩하는 것이 확실히 가능합니다.   하지만 특정 애플리케이션에 두 가지가 모두 필요할 가능성은 낮으므로 promise::set_exception()을 활용하여 처음부터 read()를 코딩해 보겠습니다. std::string read( AsyncAPI & api) { boost::fibers::promise< std::string > promise; boost::fibers::future< std::string > future( promise.get_future() ); // 'promise'과 'future'는 모두 람다가 호출될 때까지 유지됩니다. #if ! defined(BOOST_NO_CXX14_INITIALIZED_LAMBDA_CAPTURES) api.init_read([&promise]( AsyncAPI::errorcode ec, std::string const& data) mutable {   if ( ! ec) { promise.set_value( data); } else { promise.set_exception( std::make_exception_ptr( make_exception("read", ec) ) ); } }); #else // defined(BOOST_NO_CXX14_INITIALIZED_LAMBDA_CAPTURES) api.init_read( std::bind([]( boost::fibers::promise< std::string > & promise, AsyncAPI::errorcode ec, std::string const& data) mutable { if ( ! ec) { promise.set_value( data); } else { promise.set_exception( std::make_exception_ptr( make_exception("read", ec) ) ); } }, std::move( promise), std::placeholders::_1, std::placeholders::_2) ); #endif // BOOST_NO_CXX14_INITIALIZED_LAMBDA_CAPTURES return future.get(); } future::get()은 std::string을 반환하거나 예외를 발생시키는 등 올바른 작업을 수행합니다.