OneThreadPerConnectionThreadHandler类 参考

一个连接一个线程的线程模型 更多...

#include <one_thread_per_connection_thread_handler.h>

类 OneThreadPerConnectionThreadHandler 继承关系图:

Public 成员函数
virtual RC	start () override
	启动线程模型 更多...
virtual RC	stop () override
	停止线程模型 更多...
virtual RC	await_stop () override
	等待线程模型停止 更多...
virtual RC	new_connection (Communicator *communicator) override
	有新的连接到达时，调用此接口 更多...
virtual RC	close_connection (Communicator *communicator) override
	连接断开时，调用此接口。通常都是内部调用 更多...
virtual RC	start ()=0
	启动线程模型 更多...
virtual RC	stop ()=0
	停止线程模型 更多...
virtual RC	await_stop ()=0
	等待线程模型停止 更多...
virtual RC	new_connection (Communicator *communicator)=0
	有新的连接到达时，调用此接口 更多...
virtual RC	close_connection (Communicator *communicator)=0
	连接断开时，调用此接口。通常都是内部调用 更多...

Private 属性
unordered_map< Communicator *, Worker * >	thread_map_
	记录一个连接Communicator关联的线程数据
mutex	lock_
	保护线程安全的锁

额外继承的成员函数
静态 Public 成员函数 继承自 ThreadHandler
static ThreadHandler *	create (const char *name)
	创建一个线程模型

详细描述

一个连接一个线程的线程模型

成员函数说明

await_stop()

RC OneThreadPerConnectionThreadHandler::await_stop ( )

overridevirtual

等待线程模型停止

实现了 ThreadHandler.

close_connection()

RC OneThreadPerConnectionThreadHandler::close_connection ( Communicator *  communicator )

overridevirtual

连接断开时，调用此接口。通常都是内部调用

参数

communicator

与客户端通讯的对象

实现了 ThreadHandler.

new_connection()

RC OneThreadPerConnectionThreadHandler::new_connection ( Communicator *  communicator )

overridevirtual

有新的连接到达时，调用此接口

参数

communicator

与客户端通讯的对象

实现了 ThreadHandler.

start()

virtual RC OneThreadPerConnectionThreadHandler::start ( )

inlineoverridevirtual

启动线程模型

实现了 ThreadHandler.

stop()

RC OneThreadPerConnectionThreadHandler::stop ( )

overridevirtual

停止线程模型

实现了 ThreadHandler.

---

该类的文档由以下文件生成:

• src/observer/net/one_thread_per_connection_thread_handler.h
• src/observer/net/one_thread_per_connection_thread_handler.cpp