redisgate Gent boost_fiber bfiber_1000

Boost.Fiber wait_all, collecting all exceptions

wait_all, collecting all exceptions - 모든 예외 수집

wait_all_until_error_source()가 주어지면 첫 번째 오류만 표시하는 대신 모든 오류를 수집하는 wait_all_...()을 만드는 것이 더 합리적일 수 있습니다. template< typename Fn, typename ... Fns > std::vector< typename std::result_of< Fn() >::type > wait_all_collect_errors( 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); exception_list exceptions("wait_all_collect_errors() exceptions"); // 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 and/or exceptions vectors future_t future; while ( boost::fibers::channel_op_status::success == chan->pop( future) ) { std::exception_ptr exp = future.get_exception_ptr(); if ( ! exp) { results.push_back( future.get() ); } else { exceptions.add( exp); } } // if there were any exceptions, throw if ( exceptions.size() ) { throw exceptions; } // no exceptions: return vector to caller return results; } 구현은 동일한 exception_list 예외 클래스를 사용하는 wait_first_success()의 간단한 변형입니다.