redisgate Gent boost_fiber bfiber_1000

Boost.Fiber when_any, simple completion

when_any, simple completion - 간단한 완성

가장 간단한 경우는 일련의 비동기 작업 중 첫 번째 작업이 완료되었다는 사실만 알면 되는 경우입니다.
— 그러나 반환 값을 얻을 필요는 없으며 예외가 발생하지 않을 것이라고 확신합니다.

이를 위해 condition_variable 및 뮤텍스로 bool 변수를 래핑하는 Done 클래스를 도입합니다. // condition_variable + bool 플래그에 대한 표준 패턴 래핑 struct Done { private: boost::fibers::condition_variable cond; boost::fibers::mutex mutex; bool ready = false; public: typedef std::shared_ptr< Done > ptr; void wait() { std::unique_lock< boost::fibers::mutex > lock( mutex); cond.wait( lock, [this](){ return ready; }); } void notify() { { std::unique_lock< boost::fibers::mutex > lock( mutex); ready = true; } // release mutex cond.notify_one(); } }; 이 섹션 전체에서 우리가 따르는 패턴은 std::shared_ptr<>를 다양한 작업의 파이버 기능에 대한 관련 동기화 개체에 전달하는 것입니다.   이렇게 하면 마지막 파이버와 관련된 동기화 개체의 수명(lifespan)에 대한 잔소리(nagging)가 사라집니다.

wait_first_simple()은 완료에 대해 해당 전략을 사용합니다. template< typename ... Fns > void wait_first_simple( Fns && ... functions) { // 각 함수의 파이버가 별도로 바인딩되고, 마지막 파이버가 완료되기 전에 반환되므로 'shared_ptr'을 사용하세요.   auto done( std::make_shared< Done >() ); wait_first_simple_impl( done, std::forward< Fns >( functions) ... ); done->wait(); } wait_first_simple_impl()은 인수 팩에 대한 일반적인 재귀로, 각각의 새 파이버에 대해 'Done::ptr'을 캡처합니다. // 퇴화(degenerate) 경우: 기다릴 함수가 ​​없으면 즉시 반환합니다. void wait_first_simple_impl( Done::ptr) { } // 기다려야 할 함수가 하나 이상 있으면 해당 함수를 실행하고 반복하여 나머지를 처리합니다. template< typename Fn, typename ... Fns > void wait_first_simple_impl( Done::ptr done, Fn && function, Fns && ... functions) { boost::fibers::fiber( [done, function](){ function(); done->notify(); }).detach(); wait_first_simple_impl( done, std::forward< Fns >( functions) ... ); } Fiber의 람다 본문은 약속한 대로 매우 간단합니다. 함수를 호출하고 반환되면 완료를 알립니다.
이를 수행하는 첫 번째 파이버는 wait_first_simple()이 반환되도록 허용합니다.
— 이것이 바로 wait_first_simple()에서 스택 변수로 선언하는 대신 std::shared_ptr이 Done 객체의 수명을 관리하도록 하는 것이 유용한 이유입니다.

이렇게 호출할 수 있습니다. wait_first_simple( [](){ sleeper("wfs_long", 150); }, [](){ sleeper("wfs_medium", 100); }, [](){ sleeper("wfs_short", 50); }); 이 예에서는 sleeper("wfs_short", 50)가 완료되면 wait_first_simple() 이후 제어가 다시 시작됩니다.
— 다른 두 개의 sleeper() 파이버가 여전히 실행 중인데도 마찬가지입니다.