基于c++和asio的网络编程框架asio2教程基础篇：3、各个回调函数的触发线程以及多线程总结

explicit tcp_server_impl_t(
	std::size_t init_buffer_size = tcp_frame_size,
	std::size_t max_buffer_size  = (std::numeric_limits<std::size_t>::max)(),
	std::size_t concurrency      = std::thread::hardware_concurrency() * 2
)

int main()
{
	std::string_view host = "0.0.0.0";
	std::string_view port = "8028";

	// 由于tcp_server默认会启动cpu*2个数量的线程，假定cpu核数为4，那就是8个线程，
	// 假定为“线程0，线程1，...到...线程7”
	// 这里main函数的线程假定为“线程main”，（新版本asio2没有任何事件会在main线程中触发）

	asio2::tcp_server server;

	// 针对server对象启动一个定时器
	server.start_timer(123, std::chrono::seconds(1), []()
	{
		// 这个定时器的回调函数固定在“线程0”中触发
	});

	// 针对这个session_ptr投递一个异步事件
	server.post([]()
	{
		// 对这个server对象的投递的异步事件固定在“线程0”中触发
		printf("投递的异步事件被执行了\n");
	});


	server.bind_init([]()
	{
		// 固定在“线程0”中触发

	}).bind_start([&]()
	{
		// 固定在“线程0”中触发

	}).bind_accept([](std::shared_ptr<asio2::tcp_session>& session_ptr)
	{
		// 固定在“线程0”中触发

	}).bind_connect([&](auto & session_ptr)
	{
		// 固定在“线程0”中触发

		// 连接成功以后，可以给这个连接(即session_ptr)启动一个定时器
		session_ptr->start_timer("123", std::chrono::seconds(1), []()
		{
			// 这个session_ptr的定时器的回调函数和bind_recv的触发线程是同一个线程
			// (见下方bind_recv中的说明)
		});

		// 针对这个session_ptr投递一个异步事件
		session_ptr->post([]()
		{
			// 对这个session_ptr投递的异步事件的回调函数和bind_recv的触发线程是
			// 同一个线程(见下方bind_recv中的说明)
			printf("投递的异步事件被执行了\n");
		});

	}).bind_recv([&](std::shared_ptr<asio2::tcp_session> & session_ptr, std::string_view data)
	{
		// 平均分布在“线程0，线程1，...到...线程7”中触发

		// 假如session A的bind_recv在“线程2”中触发，session B的bind_recv在“线程3”中触发，
		// 那么session A的bind_recv将永远只在“线程2”中触发，不会出现一会儿在“线程2”中触发
		// 一会儿在“线程3”中触发这种情况，session B同理。

		// 对于async_send发送数据函数来说，真正发送数据时所在的线
		// 程和bind_recv的触发线程是同一个线程。

		// 假定session A的bind_recv的触发线程是“线程2”，那么session A的async_send函数也是在“线程2”
		// 中发送的数据的(不管async_send函数在哪里调用，不管在哪个线程调用，最终都是投递到“线程2”中
		// 去发送的)。
		session_ptr->async_send(data, [](std::size_t bytes_sent)
		{
			// async_send函数可以设置一个回调函数，当发送数据结束以后(不管发送成功还是发送失败)，这个
			// 回调函数就会被调用。
			// 这个回调函数也是在“线程2”中触发的。
			if (asio2::get_last_error())
				printf("发送数据失败,失败原因:%s\n", asio2::last_error_msg().c_str());
			else
				printf("发送数据成功,共发送了%d个字节\n", int(bytes_sent));
		});

	}).bind_disconnect([&](auto & session_ptr)
	{
		// 固定在“线程0”中触发

	}).bind_stop([&]()
	{
		// 固定在“线程0”中触发

	});

	server.start(host, port);

	while (std::getchar() != '\n');  // press enter to exit this program

	server.stop();

	return 0;
}

// 对于ssl有：
server.bind_handshake([&](auto & session_ptr)
{
	// 固定在“线程0”中触发
})

// 对于websocket有：
server.bind_upgrade([&](auto & session_ptr)
{
	// 固定在“线程0”中触发
})

explicit udp_server_impl_t(
	std::size_t init_buffer_size = udp_frame_size,
	std::size_t max_buffer_size  = (std::numeric_limits<std::size_t>::max)()
)

#include <asio2/asio2.hpp>

int main()
{
	std::string_view host = "0.0.0.0";
	std::string_view port = "8035";

	asio2::udp_server server;

	// 因为udp_server只有一个线程，所有的事件，包括recv,timer,post事件等，都是在“线程0”中触发的。

	server.bind_init([&]()
	{
		// 固定在“线程0”中触发

	}).bind_start([&]()
	{
		// 固定在“线程0”中触发

	}).bind_connect([](auto & session_ptr)
	{
		// 固定在“线程0”中触发

	}).bind_handshake([](auto & session_ptr)
	{
		// 固定在“线程0”中触发

		// 注意bind_handshake是针对可靠UDP的，即使用KCP时才有handshake事件，普通UDP
		// 是没有handshake事件的。但不管有没有用KCP，你调用不调用bind_handshake都
		// 可以，无所谓的，大不了不会触发而已。

	}).bind_recv([](std::shared_ptr<asio2::udp_session> & session_ptr, std::string_view s)
	{
		// 固定在“线程0”中触发

		session_ptr->async_send(s, []() {});

	}).bind_disconnect([](auto & session_ptr)
	{
		// 固定在“线程0”中触发

	}).bind_stop([&]()
	{
		// 固定在“线程0”中触发
	});

	server.start(host, port);

	while (std::getchar() != '\n');

	return 0;
}

explicit tcp_client_impl_t(
	std::size_t init_buffer_size = tcp_frame_size,
	std::size_t max_buffer_size  = (std::numeric_limits<std::size_t>::max)()
)

#include <asio2/asio2.hpp>

int main()
{
	std::string_view host = "127.0.0.1";
	std::string_view port = "8028";

	asio2::tcp_client client;

	// 因为所有客户端只有一个线程，所有的事件，包括recv,timer,post事件等，都是在“线程0”中触发的。
	
	// 注意：客户端没有start和stop事件了，实际上已经被connect和disconnect
	// 事件代替了。

	client.start_timer(1, std::chrono::seconds(1), []() {});

	client.bind_init([&]()
	{
		// 固定在“线程0”中触发

	}).bind_connect([&]()
	{
		// 固定在“线程0”中触发

		client.async_send("abc", [](std::size_t bytes) {});

	}).bind_recv([&](std::string_view sv)
	{
		// 固定在“线程0”中触发

	}).bind_disconnect([&]()
	{
		// 固定在“线程0”中触发
	});

	client.start(host, port);

	while (std::getchar() != '\n');

	return 0;
}