Do priorities in the right order, I think. Also set lower priority

Tom-Newton · Nov 28, 2024 · ff983b1 · ff983b1
1 parent 823125c
commit ff983b1
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 2 deletions.
diff --git a/cpp/src/arrow/util/parallel.h b/cpp/src/arrow/util/parallel.h
@@ -52,8 +52,10 @@ Future<std::vector<R>> ParallelForAsync(
     std::vector<T> inputs, FUNCTION&& func,
     Executor* executor = internal::GetCpuThreadPool()) {
   std::vector<Future<R>> futures(inputs.size());
+  TaskHints hints;
+  hints.priority = 10;
   for (size_t i = 0; i < inputs.size(); ++i) {
-    ARROW_ASSIGN_OR_RAISE(futures[i], executor->Submit(func, i, std::move(inputs[i])));
+    ARROW_ASSIGN_OR_RAISE(futures[i], executor->Submit(hints, func, i, std::move(inputs[i])));
   }
   return All(std::move(futures))
       .Then([](const std::vector<Result<R>>& results) -> Result<std::vector<R>> {

diff --git a/cpp/src/arrow/util/thread_pool.cc b/cpp/src/arrow/util/thread_pool.cc
@@ -56,7 +56,7 @@ struct QueuedTask {
   Task task;
   TaskHints hints;
   bool operator<(const QueuedTask& other) const {
-    return hints.priority < other.hints.priority;
+    return hints.priority > other.hints.priority;
   }
 };