处理线程导致没声音没画面问题

Author: neilyhe

app/src/main/java/com/tencent/iotvideo/link/CameraRecorder.java

@@ -162,6 +162,9 @@ private Camera.Parameters getParameters() {
 
     public void closeCamera() {
         try {
+            if (mVideoEncoder != null) {
+                mVideoEncoder.release();
+            }
             if (camera != null) {
                 camera.stopPreview();
                 camera.setPreviewCallback(null);
@@ -195,11 +198,9 @@ public void stopRecording(int visitor, int res_type) {
         }
         if (mVideoEncoder != null) {
             mVideoEncoder.stop();
-            mVideoEncoder = null;
         }
         if (mAudioEncoder != null) {
             mAudioEncoder.stop();
-            mAudioEncoder = null;
         }
         mIsRecording = false;
         mVisitorInfo.remove(visitor);
@@ -255,7 +256,7 @@ public void onVideoEncoded(byte[] datas, long pts, long seq, boolean isKeyFrame)
                 if (ret != 0) {
                     int buf_size = iv.getSendStreamBuf(visitor, channel, res_type);
                     Log.e(TAG, "sendVideoData to visitor " + visitor + " failed: " + ret + " buf size " + buf_size);
-                }else {
+                } else {
                     Log.e(TAG, "sendVideoData to success");
                 }
 

app/src/main/java/com/tencent/iotvideo/link/decoder/VideoDecoder.java

@@ -25,7 +25,7 @@ public class VideoDecoder {
     private MediaCodec mVideoCodec;
     private ExecutorService mVideoExecutor;
     private long currentVideoPts = 0;
-    private final ExecutorService decoderH264executor = Executors.newSingleThreadExecutor();
+    private ExecutorService decoderH264executor = Executors.newSingleThreadExecutor();
     private String decoderH264FilePath = "/sdcard/videoDecoder.h264";
     private FileOutputStream fos;
 
@@ -116,6 +116,9 @@ public int decoderH264(byte[] data, int len, long pts) {
     }
 
     private void saveRawDataStream(byte[] data) {
+        if (decoderH264executor.isShutdown()){
+            decoderH264executor = Executors.newSingleThreadExecutor();
+        }
         decoderH264executor.submit(() -> {
             if (fos != null) {
                 try {

app/src/main/java/com/tencent/iotvideo/link/encoder/VideoEncoder.java

@@ -36,7 +36,7 @@ public class VideoEncoder {
     private MediaCodecInfo mediaCodecInfo;
     private int colorFormat;
     private final VideoEncodeParam videoEncodeParam;
-    private final ExecutorService executor = Executors.newSingleThreadExecutor();
+    private ExecutorService executor = Executors.newSingleThreadExecutor();
     private MediaCodec mediaCodec;
     private OnEncodeListener encoderListener;
     private Range<Double> bitRateInterval;
@@ -153,7 +153,9 @@ public Range<Double> getBitRateInterval() {
      * 将NV21编码成H264
      */
     public void encoderH264(byte[] data, boolean mirror) {
-        if (executor.isShutdown()) return;
+        if (executor.isShutdown()) {
+            executor = Executors.newSingleThreadExecutor();
+        }
         executor.submit(() -> {
             byte[] readyToProcessBytes = convertData(data);
             // 获取输入缓冲区
@@ -218,6 +220,9 @@ public void stop() {
         } catch (Exception e) {
             e.printStackTrace();
         }
+    }
+
+    public void release() {
         executor.shutdown();
     }