Handle InterruptedException by Thread.interrupt()

Signed-off-by: Leo Ma <begeekmyfriend@gmail.com>

app/src/main/java/net/ossrs/sea/SrsRtmp.java

@@ -191,9 +191,8 @@ public class SrsRtmp {
             try {
                 worker.join();
             } catch (InterruptedException e) {
-                Log.i(TAG, "worker: join thread failed.");
                 e.printStackTrace();
-                worker.stop();
+                worker.interrupt();
             }
             worker = null;
             publisher = null;

app/src/main/java/net/ossrs/sea/rtmp/io/ReadThread.java

@@ -64,6 +64,7 @@ public class ReadThread extends Thread {
                 Thread.getDefaultUncaughtExceptionHandler().uncaughtException(this, ioe);
             } catch (InterruptedException ie) {
                 ie.printStackTrace();
+                this.interrupt();
             }
         }
         // Close inputstream

app/src/main/java/net/ossrs/sea/rtmp/io/RtmpConnection.java

@@ -394,6 +394,7 @@ public class RtmpConnection implements RtmpPublisher, PacketRxHandler, ThreadCon
                     thread.join();
                 } catch (InterruptedException ie) {
                     ie.printStackTrace();
+                    thread.interrupt();
                 }
             }
         }
@@ -442,4 +443,4 @@ public class RtmpConnection implements RtmpPublisher, PacketRxHandler, ThreadCon
         audio.getHeader().setAbsoluteTimestamp(dts);
         writeThread.send(audio);
     }
-}
+}