redisgate Gent boost_fiber bfiber_1000

Boost.Fiber when_all, simple completion

when_all, simple completion - 간단한 완성

모든 작업 함수가 완료될 때까지 기다려야 하지만 그 중 어느 것에서도 결과가 필요하지 않거나 예외가 예상되지 않는 경우에는 wait_first_simple()과 매우 유사하게 보이는 wait_all_simple()을 작성할 수 있습니다.   차이점은 Done 클래스 대신 장벽을 인스턴스화하고 해당 barrier::wait()을 호출한다는 것입니다.

count 파이버를 시작하고 wait_all_simple() 자체 내에서 wait() 호출을 실행하기 때문에 (count+1)로 장벽을 초기화합니다. template< typename ... Fns > void wait_all_simple( Fns && ... functions) { std::size_t count( sizeof ... ( functions) ); // 즉시 기다릴 것이기 때문에 barrier(count+1)를 초기화합니다. // 더 많은 파이버가 'count'될 때까지 깨어나고 싶지 않습니다. // 마지막 항목이 완료될 때까지 계속 유지하더라도 수명 문제에 대해 확신을 갖는 것이 더 쉽기 때문에 // 어쨌든 'shared_ptr'을 사용하십시오. auto barrier( std::make_shared< boost::fibers::barrier >( count + 1) ); wait_all_simple_impl( barrier, std::forward< Fns >( functions) ... ); barrier->wait(); } 위에서 언급한 것처럼 wait_all_simple_impl()과 wait_first_simple_impl()의 유일한 차이점은 전자가 Done::notify() 대신 barrier::wait()를 호출한다는 것입니다. template< typename Fn, typename ... Fns > void wait_all_simple_impl( std::shared_ptr< boost::fibers::barrier > barrier, Fn && function, Fns && ... functions) { boost::fibers::fiber( std::bind( []( std::shared_ptr< boost::fibers::barrier > & barrier, typename std::decay< Fn >::type & function) mutable { function(); barrier->wait(); }, barrier, std::forward< Fn >( function) )).detach(); wait_all_simple_impl( barrier, std::forward< Fns >( functions) ... ); } 다음과 같이 호출할 수 있습니다. wait_all_simple( [](){ sleeper("was_long", 150); }, [](){ sleeper("was_medium", 100); }, [](){ sleeper("was_short", 50); }); 컨트롤은 마지막 작업 함수가 완료될 때까지 wait_all_simple() 호출에서 반환되지 않습니다.