PollingRPCWorker

template<class ServiceType, typename RequestType, typename ResponseType>
class PollingRPCWorker : public FRunnable

模板参数

• class ServiceType
• typename RequestType
• typename ResponseType

继承自: public FRunnable

公共接口

构造函数

PollingRPCWorker

inline PollingRPCWorker(ServerCompletionQueue *CQueue)

参数

名称	类型	默认
CQueue	ServerCompletionQueue *	“

属性: inline

Source: Schola/Source/Schola/Public/Communicator/PollingRPCBackend.h (line 21, column 1)

析构函数

~PollingRPCWorker

inline ~PollingRPCWorker()

属性: inline

Source: Schola/Source/Schola/Public/Communicator/PollingRPCBackend.h (line 26, column 1)

公共函数

初始化

inline virtual bool Init()

初始化工作线程。

返回值: True. 因为初始化不会失败

返回: bool

属性： inline, virtual

Source: Schola/Source/Schola/Public/Communicator/PollingRPCBackend.h (line 35, column 14)

运行

inline virtual uint32 Run()

该工作线程的主方法。

返回值: 一个表示结果的状态码

返回值: uint32

属性： inline, virtual

Source: Schola/Source/Schola/Public/Communicator/PollingRPCBackend.h (line 45, column 16)

Start

inline void Start()

启动工作线程。

属性: inline

Source: Schola/Source/Schola/Public/Communicator/PollingRPCBackend.h (line 92, column 6)

停止

inline virtual void Stop()

关闭工作线程及其关联的完成队列。

属性： inline, virtual

Source: Schola/Source/Schola/Public/Communicator/PollingRPCBackend.h (line 101, column 14)

退出

inline virtual void Exit()

属性： inline, virtual

Source: Schola/Source/Schola/Public/Communicator/PollingRPCBackend.h (line 112, column 14)

公共成员

FRunnableThread * Thread

FRunnableThread * Thread = = nullptr

Source: Schola/Source/Schola/Public/Communicator/PollingRPCBackend.h (line 18, column 16)

TQueue<RequestType> Requests

TQueue<RequestType> Requests = = TQueue<RequestType>()

Source: Schola/Source/Schola/Public/Communicator/PollingRPCBackend.h (line 19, column 8)

私有接口

私有成员

ServerCompletionQueue * CQueue

ServerCompletionQueue * CQueue

属性: private

Source: Schola/Source/Schola/Public/Communicator/PollingRPCBackend.h (line 15, column 23)

Used By: PollingRPCBackend

Source: Schola/Source/Schola/Public/Communicator/PollingRPCBackend.h (line 10, column 1)