| Index: webrtc/base/task_queue.h
|
| diff --git a/webrtc/base/task_queue.h b/webrtc/base/task_queue.h
|
| index c5229b1fe25addd14b4fee55259d0b1665c48857..15b31aa71771c62390fd93e558daed2c4c28f180 100644
|
| --- a/webrtc/base/task_queue.h
|
| +++ b/webrtc/base/task_queue.h
|
| @@ -13,6 +13,7 @@
|
|
|
| #include <list>
|
| #include <memory>
|
| +#include <queue>
|
|
|
| #if defined(WEBRTC_MAC) && !defined(WEBRTC_BUILD_LIBEVENT)
|
| #include <dispatch/dispatch.h>
|
| @@ -274,6 +275,7 @@ class LOCKABLE TaskQueue {
|
| QueueContext* const context_;
|
| #elif defined(WEBRTC_WIN)
|
| class ThreadState;
|
| + void RunPendingTasks();
|
| static void ThreadMain(void* context);
|
|
|
| class WorkerThread : public PlatformThread {
|
| @@ -289,6 +291,9 @@ class LOCKABLE TaskQueue {
|
| }
|
| };
|
| WorkerThread thread_;
|
| + rtc::CriticalSection pending_lock_;
|
| + std::queue<std::unique_ptr<QueuedTask>> pending_ GUARDED_BY(pending_lock_);
|
| + HANDLE in_queue_;
|
| #else
|
| #error not supported.
|
| #endif
|
|
|