redisgate Gent boost_fiber bfiber_1000

Boost.Fiber when_any, return value

when_any, return value - 반환 값

완료할 작업 함수 중 첫 번째 함수부터 반환 값을 캡처하는 기능을 추가하는 것이 더 유용한 것 같습니다.
다시 말하지만, 누구도 예외를 발생시키지 않을 것이라고 가정합니다.

한 가지 전략은 단순한 부울 대신 첫 번째 반환 값을 저장하도록 Done 클래스를 조정하는 것입니다.
그러나 우리는 대신 buffered_channel<>을 사용하기로 선택했습니다.
첫 번째 값만 대기열에 추가하면 되므로 해당 값을 검색한 후에는 buffered_channel::close()를 수행합니다.
후속 push() 호출은 닫힌 상태로 반환됩니다. // 전달된 모든 함수의 반환 유형이 동일하다고 가정합니다. // wait_first_value()의 반환 유형은 처음 전달된 함수의 반환 유형입니다. // NO 함수를 전달하는 것은 단순히 유효하지 않습니다. template< typename Fn, typename ... Fns > typename std::result_of< Fn() >::type wait_first_value( Fn && function, Fns && ... functions) { typedef typename std::result_of< Fn() >::type return_t; typedef boost::fibers::buffered_channel< return_t > channel_t; auto chanp( std::make_shared< channel_t >( 64) ); // 모든 관련 파이버를 실행 wait_first_value_impl< return_t >( chanp, std::forward< Fn >( function), std::forward< Fns >( functions) ... ); // retrieve the first value return_t value( chanp->value_pop() ); // 채널을 닫습니다. 후속 push()가 성공할 필요가 없습니다. chanp->close(); return value; } wait_first_value_impl() 함수의 핵심은 예상한 대로입니다: template< typename T, typename Fn > void wait_first_value_impl( std::shared_ptr< boost::fibers::buffered_channel< T > > chan, Fn && function) { boost::fibers::fiber( [chan, function](){ // push()에서 반환된 'channel_op_status'를 무시합니다. // 닫힐 수도 있습니다. 우리는 단순히 상관하지 않습니다. chan->push( function() ); }).detach(); } 전달된 함수를 호출하고 반환 값을 푸시하며 push() 결과를 무시합니다.
다음과 같이 호출할 수 있습니다. std::string result = wait_first_value( [](){ return sleeper("wfv_third", 150); }, [](){ return sleeper("wfv_second", 100); }, [](){ return sleeper("wfv_first", 50); }); std::cout << "wait_first_value() => " << result << std::endl; assert(result == "wfv_first");