WebRTC的TaskQueue原始碼分析

taskqueue的中文翻譯是「任務佇列」，顧名思義，它的作用就是把一些「任務」儲存在佇列中，然後再從佇列中取出任務並執行。由於佇列是fifo，所以任務佇列具有有序性。

**提供的介面是posttask(std::unique_ptr task)：

void taskqueue::posttask(std::unique_ptrtask)

posttask作用是將任務傳遞給taskqueue::impl_ ，impl_ 是taskqueue中的內部類impl的例項，當任務傳遞至impl中的posttask函式後，會將任務推送至佇列pending_中。

void taskqueue::impl::posttask(std::unique_ptrtask)

void channel::processandencodeaudio;

processandencodeaudio函式對音訊幀audio_frame進行判斷、處理後，將會執行

encoder_queue_->posttask(std::unique_ptr(
new processandencodeaudiotask(std::move(audio_frame), this)));

這樣，就把編碼一幀音訊的任務放到了任務佇列中encoder_queue_，然後processandencodeaudiotask會被非同步執行。當有很多幀音訊被放進encoder_queue__中之後，由於佇列的fifo特性，會將音訊幀按照採集順序依次進行編碼。

taskqueue的設計很巧妙，把乙個個closure放進佇列中，然後在執行執行緒中把任務closure取出後執行。

這樣能夠保證同乙個taskqueue物件中的任務，都會在乙個執行緒內執行，並且具有先後順序。此外，處理不同型別的任務，只要new出不同的taskqueue物件就可以，十分方便，這是因為taskqueue中佇列儲存的是closure，而不是具體的物件或指標。