diff --git a/client/Client.cpp b/client/Client.cpp index b8efb0c..3c7f413 100644 --- a/client/Client.cpp +++ b/client/Client.cpp @@ -68,12 +68,10 @@ bool BaseClient::Login(const std::string &nickname) { } void BaseClient::StartReceive() { - isRunning_ = true; receiveThread_ = std::jthread(&BaseClient::ReceiveLoop, this); } void BaseClient::StopReceive() { - isRunning_ = false; boost::system::error_code ec; socket_.shutdown(tcp::socket::shutdown_both, ec); socket_.close(ec); @@ -82,7 +80,7 @@ void BaseClient::StopReceive() { void BaseClient::ReceiveLoop(std::stop_token stopToken) { try { - while (!stopToken.stop_requested() && isRunning_) { + while (!stopToken.stop_requested()) { PacketHeader header; if (!ReceiveHeader(header)) break; diff --git a/include/Client.h b/include/Client.h index 3379ecd..b30f57d 100644 --- a/include/Client.h +++ b/include/Client.h @@ -44,7 +44,6 @@ protected: std::string nickname_; std::jthread receiveThread_; - std::atomic isRunning_{false}; void ReceiveLoop(std::stop_token stopToken); void HandlePacket(const PacketHeader &header);