|
CGraph
|
事件机制,addGEvent将事件注册到pipeline notify触发,process处理信号,trigger同步执行,asyncProcess异步执行,asyncWait等待异步任务结束 More...
#include <GEvent.h>


Protected Member Functions | |
| virtual CVoid | trigger (GEventParamPtr param)=0 |
| GEvent () | |
| ~GEvent () override | |
Protected Member Functions inherited from GEventObject | |
| CStatus | run () final |
| virtual GEventObject * | setThreadPool (UThreadPoolPtr ptr) |
Private Member Functions | |
| CStatus | init () final |
| CStatus | destroy () final |
| CStatus | process (GEventType type, GEventAsyncStrategy strategy) |
| std::shared_future< CVoid > | asyncProcess (GEventAsyncStrategy strategy) |
| CVoid | asyncWait (GEventAsyncStrategy strategy) |
Private Attributes | |
| std::vector< std::shared_future< CVoid > > | async_run_finish_futures_ {} |
| std::vector< std::shared_future< CVoid > > | async_destroy_futures_ {} |
| GEventParamPtr | param_ { nullptr } |
| std::mutex | async_run_finished_lock_ |
| std::mutex | async_destroy_lock_ |
Friends | |
| class | GEventManager |
Additional Inherited Members | |
Public Member Functions inherited from CObject | |
| CObject ()=default | |
| virtual | ~CObject ()=default |
Public Member Functions inherited from CDescInfo | |
| virtual const std::string & | getName () const |
| const std::string & | getSession () const |
| const std::string & | getDescription () const |
| virtual auto | setName (const std::string &name) -> decltype(this) |
| virtual auto | setDescription (const std::string &description) -> decltype(this) |
| virtual | ~CDescInfo ()=default |
Protected Attributes inherited from GEventObject | |
| UThreadPoolPtr | thread_pool_ = nullptr |
| GParamManagerPtr | param_manager_ = nullptr |
Protected Attributes inherited from CDescInfo | |
| std::string | name_ |
| std::string | session_ |
| std::string | description_ |
事件机制,addGEvent将事件注册到pipeline notify触发,process处理信号,trigger同步执行,asyncProcess异步执行,asyncWait等待异步任务结束
|
explicitprotected |

|
overrideprotected |
|
private |
异步事件处理
| strategy |
根据具体策略,将 future信息放到对应的容器中 在特定的时间点,等待执行结束

|
private |
等待并清理所有异步的event逻辑
| strategy |
|
finalprivatevirtual |
|
private |
处理信号事件
| type | |
| strategy |

|
protectedpure virtual |
|
friend |
|
private |
|
private |
|
private |
|
private |
|
private |