diff --git a/services/source/transport/src/distributed_input_source_transport.cpp b/services/source/transport/src/distributed_input_source_transport.cpp
index 9580c4c..df8a4bd 100644
--- a/services/source/transport/src/distributed_input_source_transport.cpp
+++ b/services/source/transport/src/distributed_input_source_transport.cpp
@@ -480,6 +480,7 @@ void DistributedInputSourceTransport::OnSessionClosed(int32_t sessionId)
         sessionDevMap_.erase(deviceId);
     }
     channelStatusMap_.erase(deviceId);
+    StopLatencyThread();
     DistributedInputInject::GetInstance().StopInjectThread();
 }