手动刷新io

Author: CppCXY

CodeFormatServer/src/Session/IOSession.cpp

@@ -25,7 +25,7 @@ int IOSession::Run(asio::io_context& ioc)
 		while(true)
 		{
 			ioc.run();
-			std::this_thread::yield();
+			std::this_thread::sleep_for(std::chrono::milliseconds(1));
 		}
 	});
 	t.detach();
@@ -47,10 +47,10 @@ std::string IOSession::Handle(std::shared_ptr<ProtocolParser> parser)
 			{
 				return parser->SerializeProtocol(result);
 			}
-			std::cerr << format("request {}, it cost: {}ms\n", parser->GetMethod(),
-			                    chrono::duration_cast<chrono::milliseconds>(
-				                    chrono::system_clock::now() - start
-			                    ).count());
+			// std::cerr << format("request {}, it cost: {}ms\n", parser->GetMethod(),
+			//                     chrono::duration_cast<chrono::milliseconds>(
+			// 	                    chrono::system_clock::now() - start
+			//                     ).count());
 		}
 	}
 	catch (std::exception& e)

CodeFormatServer/src/Session/StandardIOSession.cpp

@@ -77,13 +77,16 @@ bool StandardIO::HasError()
 void StandardIO::Write(std::string_view content)
 {
 	std::cout.write(content.data(), content.size());
+	std::cout.flush();
 }
 
 #endif
 
 
 int StandardIOSession::Run(asio::io_context& ioc)
 {
+	// std::this_thread::sleep_for(std::chrono::seconds(15));
+	IOSession::Run(ioc);
 	while (true)
 	{
 		do