redisgate Gent boost_fiber bfiber_1000

Boost.Fiber when_all until first exception

when_all until first exception - 첫 번째 예외가 발생할 때까지

당연히 wait_first_outcome()과 마찬가지로 일반 T 대신 future< T >를 전달하여 wait_all_values() 및 wait_all_values_source()를 정교하게 만들 수 있습니다.

wait_all_until_error()는 future< T >를 팝하고 future::get()을 호출합니다. template< typename Fn, typename ... Fns > std::vector< typename std::result_of< Fn() >::type > wait_all_until_error( Fn && function, Fns && ... functions) { std::size_t count( 1 + sizeof ... ( functions) ); typedef typename std::result_of< Fn() >::type return_t; typedef typename boost::fibers::future< return_t > future_t; typedef std::vector< return_t > vector_t; vector_t results; results.reserve( count); // get channel std::shared_ptr< boost::fibers::buffered_channel< future_t > > chan( wait_all_until_error_source( std::forward< Fn >( function), std::forward< Fns >( functions) ... ) ); // fill results vector future_t future; while ( boost::fibers::channel_op_status::success == chan->pop( future) ) { results.push_back( future.get() ); } // return vector to caller return results; } 예를 들어: std::string thrown; try { std::vector< std::string > values = wait_all_until_error( [](){ return sleeper("waue_late", 150); }, [](){ return sleeper("waue_middle", 100, true); }, [](){ return sleeper("waue_early", 50); }); } catch ( std::exception const& e) { thrown = e.what(); } std::cout << "wait_all_until_error(fail) threw '" << thrown << "'" << std::endl; 당연히 이것은 wait_all_until_error_source()에 대한 API를 복잡하게 만듭니다.   호출자는 future< T >를 검색하고 해당 get() 메서드를 호출해야 합니다.   물론, 암시적으로 get()을 수행하고 간단한 T(또는 throw)를 반환하는 대기열의 소비자 측에 대한 façade를 반환하는 것이 가능할 것입니다.

구현은 예상한 대로입니다.   그러나 queue 대신 nqueue를 전달하여 wait_first_outcome_impl()을 재사용할 수 있습니다. // 호출자가 'closed' 때까지 새로운 결과가 도착할 때마다 get()할 수 있는 // shared_ptr<buffered_channel<future<T>>>를 반환합니다. template< typename Fn, typename ... Fns > std::shared_ptr< boost::fibers::buffered_channel< boost::fibers::future< typename std::result_of< Fn() >::type > > > wait_all_until_error_source( Fn && function, Fns && ... functions) { std::size_t count( 1 + sizeof ... ( functions) ); typedef typename std::result_of< Fn() >::type return_t; typedef boost::fibers::future< return_t > future_t; typedef boost::fibers::buffered_channel< future_t > channel_t; // make the channel auto chanp( std::make_shared< channel_t >( 64) ); // and make an nchannel facade to close it after 'count' items auto ncp( std::make_shared< nchannel< future_t > >( chanp, count) ); // 해당 nchannel 파사드를 모든 관련 파이버에 전달합니다. wait_first_outcome_impl< return_t >( ncp, std::forward< Fn >( function), std::forward< Fns >( functions) ... ); // then return the channel for consumer return chanp; } 예를 들어: typedef boost::fibers::future< std::string > future_t; std::shared_ptr< boost::fibers::buffered_channel< future_t > > chan = wait_all_until_error_source( [](){ return sleeper("wauess_third", 150); }, [](){ return sleeper("wauess_second", 100); }, [](){ return sleeper("wauess_first", 50); }); future_t future; while ( boost::fibers::channel_op_status::success == chan->pop( future) ) { std::string value( future.get() ); std::cout << "wait_all_until_error_source(success) => '" << value << "'" << std::endl; }