解决priority_queue改进唤醒逻辑后导致容易hang死的bug

b3d3c873 · yq0 · wangzelin.wzl · 5f0ce95c · b3d3c873
隐藏空白更改
内联并排

Showing with 1 addition and 1 deletion

deps/oblib/src/lib/queue/ob_priority_queue.h deps/oblib/src/lib/queue/ob_priority_queue.h +1 -1

未找到文件。
--- a/deps/oblib/src/lib/queue/ob_priority_queue.h
+++ b/deps/oblib/src/lib/queue/ob_priority_queue.h
@@ -172,7 +172,7 @@ public:

  int pop_high(ObLink*& data, int64_t timeout_us)
  {
-    return do_pop(data, HIGH_PRIOS, timeout_us);
+    return do_pop(data, HIGH_HIGH_PRIOS + HIGH_PRIOS, timeout_us);
  }

  int pop_high_high(ObLink*& data, int64_t timeout_us)