\r
void decode_next_frame()\r
{\r
- for(int n = 0; n < 64 && muxer_.empty(); ++n)\r
- { \r
- std::shared_ptr<AVFrame> video;\r
- std::shared_ptr<core::audio_buffer> audio;\r
-\r
- tbb::parallel_invoke\r
- (\r
- [&]\r
- {\r
- if(!muxer_.video_ready())\r
- video = video_decoder_();\r
- },\r
- [&]\r
- { \r
- if(!muxer_.audio_ready())\r
- audio = audio_decoder_(); \r
- }\r
- );\r
- \r
- muxer_.push(video);\r
- muxer_.push(audio);\r
+ for(int n = 0; n < 8 && muxer_.empty(); ++n)\r
+ { \r
+ if(!muxer_.video_ready())\r
+ muxer_.push(video_decoder_());\r
+ if(!muxer_.audio_ready())\r
+ muxer_.push(audio_decoder_());\r
}\r
graph_->set_text(print());\r
}\r