redisgate Gent boost_fiber bfiber_0800

Boost.Fiber Integrating Fibers with Asynchronous Callbacks - Return Errorcode

Integrating Fibers with Asynchronous Callbacks - Return Errorcode

비동기 콜백과 파이버 통합 - 반환 오류 코드

AsyncAPI::init_write() 콜백은 오류 코드만 전달합니다.
단순히 차단 래퍼가 해당 오류 코드를 반환하도록 하려면 promise<>와 future<>를 매우 간단하게 사용하면 됩니다. AsyncAPI::errorcode write_ec( AsyncAPI & api, std::string const& data) { boost::fibers::promise< AsyncAPI::errorcode > promise; boost::fibers::future< AsyncAPI::errorcode > future( promise.get_future() ); // 일반적으로 future::get()에 대한 대기를 차단하고 따라서 promise::set_value()가 // 호출될 때까지 'promise'를 파기하지 않더라도 스레드를 사용하면 ~promise()가 가능하다는 점을 알 수 있습니다.   // promise::set_value()가 반환되기 전에 입력되었습니다. // 'fibers::promise'에서는 그런 일이 발생해서는 안 되지만, 수명 문제를 처리하는 // 강력한 방법은 'promise'를 람다에 바인딩하는 것입니다. // 'promise'는 이동 전용(move-only)이므로 초기화 캡처를 사용하세요. #if ! defined(BOOST_NO_CXX14_INITIALIZED_LAMBDA_CAPTURES) api.init_write( data, [promise=std::move( promise)]( AsyncAPI::errorcode ec) mutable { promise.set_value( ec); }); #else // defined(BOOST_NO_CXX14_INITIALIZED_LAMBDA_CAPTURES) api.init_write( data, std::bind([](boost::fibers::promise< AsyncAPI::errorcode > & promise, AsyncAPI::errorcode ec) { promise.set_value( ec); }, std::move( promise), std::placeholders::_1) ); #endif // BOOST_NO_CXX14_INITIALIZED_LAMBDA_CAPTURES return future.get(); }
우리가 해야 할 일은 다음과 같습니다:

1. 올바른 유형의 promise<>를 인스턴스화합니다.
2. future<>를 얻습니다.
3. promise::set_value()를 호출하도록 콜백을 준비합니다.
4. future::get()을 차단합니다.

• Note
보류 중인 파이버를 재개하는 이 전략은 시작 파이버가 실행 중인 스레드가 아닌 다른 스레드에서 콜백이 호출되는 경우에도 작동합니다.   실제로 예제 프로그램의 더미 AsyncAPI 구현은 다음을 보여줍니다.   잠시 대기하는 새 스레드를 시작한 다음 관련 콜백을 호출하여 비동기 I/O를 시뮬레이션합니다.