FFTPlayer0x33 use double packet queue, double decoder thread

Author: debugly

FFmpegTutorial/t33/FFTPlayer0x33.m

@@ -41,7 +41,8 @@ @interface  FFTPlayer0x33 ()<FFTDecoderDelegate>
     //音频重采样
     FFTAudioResample *_audioResample;
 
-    FFTPacketQueue *_packetQueue;
+    FFTPacketQueue *_audioPacketQueue;
+    FFTPacketQueue *_videoPacketQueue;
 
     FFTVideoFrameQueue *_videoFrameQueue;
     FFTAudioFrameQueue *_audioFrameQueue;
@@ -62,7 +63,8 @@ @interface  FFTPlayer0x33 ()<FFTDecoderDelegate>
 
 //读包线程
 @property (nonatomic, strong) FFTThread *readThread;
-@property (nonatomic, strong) FFTThread *decoderThread;
+@property (nonatomic, strong) FFTThread *audioDecoderThread;
+@property (nonatomic, strong) FFTThread *videoDecoderThread;
 @property (nonatomic, strong) FFTThread *videoThread;
 
 @property (atomic, assign) int abort_request;
@@ -85,7 +87,8 @@ static int decode_interrupt_cb(void *ctx)
 - (void)_stop
 {
     self.abort_request = 1;
-    [_packetQueue cancel];
+    [_audioPacketQueue cancel];
+    [_videoPacketQueue cancel];
     [_videoFrameQueue cancel];
     [_audioFrameQueue cancel];
 
@@ -100,9 +103,14 @@ - (void)_stop
         [self.readThread join];
     }
 
-    if (self.decoderThread) {
-        [self.decoderThread cancel];
-        [self.decoderThread join];
+    if (self.audioDecoderThread) {
+        [self.audioDecoderThread cancel];
+        [self.audioDecoderThread join];
+    }
+    
+    if (self.videoDecoderThread) {
+        [self.videoDecoderThread cancel];
+        [self.videoDecoderThread join];
     }
 
     if (self.videoThread) {
@@ -132,13 +140,17 @@ - (void)prepareToPlay
         NSAssert(NO, @"不允许重复创建");
     }
 
-    _packetQueue = [[FFTPacketQueue alloc] init];
+    _audioPacketQueue = [[FFTPacketQueue alloc] init];
+    _videoPacketQueue = [[FFTPacketQueue alloc] init];
 
     self.readThread = [[FFTThread alloc] initWithTarget:self selector:@selector(readPacketsFunc) object:nil];
     self.readThread.name = @"mr-read";
 
-    self.decoderThread = [[FFTThread alloc] initWithTarget:self selector:@selector(decoderFunc) object:nil];
-    self.decoderThread.name = @"mr-decoder";
+    self.audioDecoderThread = [[FFTThread alloc] initWithTarget:self selector:@selector(audioDecoderFunc) object:nil];
+    self.audioDecoderThread.name = @"audio-decoder";
+    
+    self.videoDecoderThread = [[FFTThread alloc] initWithTarget:self selector:@selector(videoDecoderFunc) object:nil];
+    self.videoDecoderThread.name = @"video-decoder";
 
     self.videoThread = [[FFTThread alloc] initWithTarget:self selector:@selector(videoThreadFunc) object:nil];
     self.videoThread.name = @"mr-v-display";
@@ -171,9 +183,9 @@ - (void)readPacketLoop:(AVFormatContext *)formatCtx
                 pkt->data = NULL;
                 pkt->size = 0;
                 pkt->stream_index = _videoDecoder.streamIdx;
-                [_packetQueue enQueue:pkt];
+                [_videoPacketQueue enQueue:pkt];
                 pkt->stream_index = _audioDecoder.streamIdx;
-                [_packetQueue enQueue:pkt];
+                [_audioPacketQueue enQueue:pkt];
                 break;
             }
 
@@ -192,15 +204,15 @@ - (void)readPacketLoop:(AVFormatContext *)formatCtx
                     if (pkt->data != NULL) {
                         self.videoPktCount++;
                     }
-                    [_packetQueue enQueue:pkt];
+                    [_videoPacketQueue enQueue:pkt];
                 }
                     break;
                 case AVMEDIA_TYPE_AUDIO:
                 {
                     if (pkt->data != NULL) {
                         self.audioPktCount++;
                     }
-                    [_packetQueue enQueue:pkt];
+                    [_audioPacketQueue enQueue:pkt];
                 }
                     break;
                 default:
@@ -365,8 +377,9 @@ - (void)readPacketsFunc
     });
 
     _formatCtx = formatCtx;
-    [self.decoderThread start];
-    //[self.videoThread start];
+    [self.audioDecoderThread start];
+    [self.videoDecoderThread start];
+
     //循环读包
     [self readPacketLoop:formatCtx];
 }
@@ -481,11 +494,24 @@ - (void)decodePkt:(AVPacket *)pkt
     }
 }
 
-- (void)decoderFunc
+- (void)audioDecoderFunc
+{
+    while (!self.abort_request) {
+        __weakSelf__
+        [_audioPacketQueue deQueue:^(AVPacket * pkt) {
+            __strongSelf__
+            if (pkt) {
+                [self decodePkt:pkt];
+            }
+        }];
+    }
+}
+
+- (void)videoDecoderFunc
 {
     while (!self.abort_request) {
         __weakSelf__
-        [_packetQueue deQueue:^(AVPacket * pkt) {
+        [_videoPacketQueue deQueue:^(AVPacket * pkt) {
             __strongSelf__
             if (pkt) {
                 [self decodePkt:pkt];
@@ -494,6 +520,7 @@ - (void)decoderFunc
     }
 }
 
+
 #pragma mark - FFTDecoderDelegate
 
 - (void)decoder:(FFTDecoder *)decoder reveivedAFrame:(AVFrame *)aFrame