redisgate Gent boost_fiber bfiber_1000

Boost.Fiber when_any, heterogeneous types

when_any, heterogeneous types - 이기종 유형

다양한 작업 함수가 서로 다른 반환 유형을 갖는 경우를 무시하면 안 됩니다.   이는 첫 번째 항목에서 반환된 값이 해당 유형 중 하나를 가질 수 있음을 의미합니다.   'Boost.Variant'를 사용하여 이를 표현할 수 있습니다.

예제를 단순하게 유지하기 위해 이들 중 어느 것도 예외를 발생시킬 수 없는 척하는 것으로 되돌아가겠습니다.   이는 wait_first_value_het()이 wait_first_value()와 매우 유사하게 만듭니다.   우리는 실제로 wait_first_value_impl()을 재사용할 수 있으며, 단지 boost::variant를 공통 T가 아닌 대기열의 값 유형으로 전달하기만 하면 됩니다!

당연히 이것은 wait_first_success() 의미 체계를 대신 사용하도록 확장될 수 있습니다. // 인터페이스 함수에 대한 첫 번째 Fn을 중단할 필요가 없습니다. 비어 있으면 컴파일러가 불평하도록 합니다. // 함수에는 다양한 반환 유형이 있으므로 그 중 하나를 반환해야 할 수도 있습니다. // 매개변수 팩의 각 Fn에 대해 'std::result_of<Fn()>::type'을 확장하는 변형을 사용합니다. template< typename ... Fns > boost::variant< typename std::result_of< Fns() >::type ... > wait_first_value_het( Fns && ... functions) { // Use buffered_channel<boost::variant<T1, T2, ...>>; see remarks above. typedef boost::variant< typename std::result_of< Fns() >::type ... > return_t; typedef boost::fibers::buffered_channel< return_t > channel_t; auto chanp( std::make_shared< channel_t >( 64) ); // launch all the relevant fibers wait_first_value_impl< return_t >( chanp, std::forward< Fns >( functions) ... ); // retrieve the first value return_t value( chanp->value_pop() ); // close the channel: no subsequent push() has to succeed chanp->close(); return value; } 다음과 같이 호출될 수 있습니다. boost::variant< std::string, double, int > result = wait_first_value_het( [](){ return sleeper("wfvh_third", 150); }, [](){ return sleeper(3.14, 100); }, [](){ return sleeper(17, 50); }); std::cout << "wait_first_value_het() => " << result << std::endl; assert(boost::get< int >( result) == 17);