redisgate Gent boost_fiber bfiber_0800

Boost.Fiber Integrating Fibers with Asynchronous Callbacks - Success/Error Virtual Methods

Integrating Fibers with Asynchronous Callbacks - Virtual Methods

비동기 콜백과 파이버 통합 - 성공/오류 가상 메서드

완료 알림에 대한 일반적인 접근 방식 중 하나는 success() 및 error() 메서드를 사용하여 추상 기본 클래스(abstract base class)를 정의하는 것입니다.   비동기 I/O를 수행하려는 코드는 하위 클래스를 파생시키고, 이러한 각 메서드를 재정의하고, 비동기 작업에 하위 클래스 인스턴스에 대한 포인터를 전달해야 합니다.
추상 기본 클래스는 다음과 같습니다. // 모든 비동기 작업은 결과를 전달하기 위해 이 추상 기본 클래스의 하위 클래스 인스턴스를 받습니다. struct Response { typedef std::shared_ptr< Response > ptr; // 작업이 성공하면 호출됩니다. virtual void success( std::string const& data) = 0; // 작업이 실패하면 호출됩니다. virtual void error( AsyncAPIBase::errorcode ec) = 0; };

이제 AsyncAPI 작업은 다음과 유사할 수 있습니다. // Response 서브클래스 파생, 인스턴스화, Response::ptr 전달 void init_read( Response::ptr);

모든 경우에 적용되는 단일형(one-size-fits-all) 'PromiseResponse'를 작성하여 이 문제를 해결할 수 있습니다. class PromiseResponse: public Response { public: // 작업이 성공하면 호출됩니다. virtual void success( std::string const& data) { promise_.set_value( data); } // 작업이 실패하면 호출됩니다. virtual void error( AsyncAPIBase::errorcode ec) { promise_.set_exception( std::make_exception_ptr( make_exception("read", ec) ) ); } boost::fibers::future< std::string > get_future() { return promise_.get_future(); } private: boost::fibers::promise< std::string > promise_; };

이제 'PromiseResponse'에서 future<>를 얻고 get()을 기다릴 수 있습니다. std::string read( AsyncAPI & api) { // Because init_read() requires a shared_ptr, we must allocate our // ResponsePromise on the heap, even though we know its lifespan. auto promisep( std::make_shared< PromiseResponse >() ); boost::fibers::future< std::string > future( promisep->get_future() ); // Both 'promisep' and 'future' will survive until our lambda has been // called. api.init_read( promisep); return future.get(); } 위의 소스 코드는 adapt_callbacks.cpp 및 adapt_method_calls.cpp에 있습니다.
⚛ adapt_callbacks.cpp
⚛ adapt_method_calls.cpp