paleolimbot commented on code in PR #13706:
URL: https://github.com/apache/arrow/pull/13706#discussion_r957344761
##########
r/src/threadpool.cpp:
##########
@@ -54,3 +54,17 @@ int GetIOThreadPoolCapacity() { return
arrow::io::GetIOThreadPoolCapacity(); }
void SetIOThreadPoolCapacity(int threads) {
StopIfNotOk(arrow::io::SetIOThreadPoolCapacity(threads));
}
+
+namespace arrow {
+namespace io {
+namespace internal {
+arrow::internal::ThreadPool* GetIOThreadPool();
+}
+} // namespace io
+} // namespace arrow
+
+// [[arrow::export]]
+void WaitForIdleThreadPool() {
Review Comment:
There's currently no option to specify a wait period (which is why I fenced
it to `on_linux_dev()`)...I'd like to fire off a few more valgrind checks to
make sure that it actually fixes the problem. Practically it doesn't matter
(this occurs when shutting down the process).
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
