commit c9bb7918f6c3dec9b3d583bbf2fc53e74ea875b6
author tommi <tommi@webrtc.org> Fri Feb 24 10:42:14 2017 -0800
committer Commit bot <commit-bot@chromium.org> Fri Feb 24 18:42:14 2017 +0000
tree 2451411e7cc258e1bcb0ee8bafec843ba1f15eb2
parent 3ba1a8cd1b875dc7bfcb7075fe4f78d0dfe0ff98

Add support for priorities to TaskQueue.

BUG=webrtc:7216

Review-Url: https://codereview.webrtc.org/2708353003
Cr-Commit-Position: refs/heads/master@{#16834}

webrtc/base/task_queue_win.cc

diff --git a/webrtc/base/task_queue_win.cc b/webrtc/base/task_queue_win.cc
index c8ef721..5850b29 100644
--- a/webrtc/base/task_queue_win.cc
+++ b/webrtc/base/task_queue_win.cc
@@ -24,6 +24,8 @@
 #define WM_RUN_TASK WM_USER + 1
 #define WM_QUEUE_DELAYED_TASK WM_USER + 2
 
+using Priority = TaskQueue::Priority;
+
 DWORD g_queue_ptr_tls = 0;
 
 BOOL CALLBACK InitializeTls(PINIT_ONCE init_once, void* param, void** context) {
@@ -49,6 +51,21 @@
   ::TlsSetValue(GetQueuePtrTls(), data->thread_context);
   data->started->Set();
 }
+
+ThreadPriority TaskQueuePriorityToThreadPriority(Priority priority) {
+  switch (priority) {
+    case Priority::HIGH:
+      return kRealtimePriority;
+    case Priority::LOW:
+      return kLowPriority;
+    case Priority::NORMAL:
+      return kNormalPriority;
+    default:
+      RTC_NOTREACHED();
+      break;
+  }
+  return kNormalPriority;
+}
 }  // namespace
 
 class TaskQueue::MultimediaTimer {
@@ -145,8 +162,11 @@
   RTC_DISALLOW_COPY_AND_ASSIGN(MultimediaTimer);
 };
 
-TaskQueue::TaskQueue(const char* queue_name)
-    : thread_(&TaskQueue::ThreadMain, this, queue_name) {
+TaskQueue::TaskQueue(const char* queue_name, Priority priority /*= NORMAL*/)
+    : thread_(&TaskQueue::ThreadMain,
+              this,
+              queue_name,
+              TaskQueuePriorityToThreadPriority(priority)) {
   RTC_DCHECK(queue_name);
   thread_.Start();
   Event event(false, false);