diff --git a/app/src/main/java/net/ossrs/sea/rtmp/io/RtmpConnection.java b/app/src/main/java/net/ossrs/sea/rtmp/io/RtmpConnection.java
index ce48de1..29f1ed4 100644
--- a/app/src/main/java/net/ossrs/sea/rtmp/io/RtmpConnection.java
+++ b/app/src/main/java/net/ossrs/sea/rtmp/io/RtmpConnection.java
@@ -390,6 +390,11 @@ public class RtmpConnection implements RtmpPublisher, PacketRxHandler, ThreadCon
                 } else if (thread instanceof WriteThread && thread.isAlive()) {
                     ((WriteThread) thread).shutdown();
                 }
+                try {
+                    thread.join();
+                } catch (InterruptedException ie) {
+                    ie.printStackTrace();
+                }
             }
         }
         if (socket != null) {
@@ -437,4 +442,4 @@ public class RtmpConnection implements RtmpPublisher, PacketRxHandler, ThreadCon
         audio.getHeader().setAbsoluteTimestamp(dts);
         writeThread.send(audio);
     }
-}
\ No newline at end of file
+}