We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent e1f9bbb commit dba0411Copy full SHA for dba0411
vortex-io/src/runtime/uring.rs
@@ -17,6 +17,7 @@ use kanal::Receiver;
17
use kanal::Sender;
18
use monoio::IoUringDriver;
19
use monoio::RuntimeBuilder;
20
+use monoio::blocking::DefaultThreadPool;
21
use vortex_error::vortex_panic;
22
23
use crate::runtime::AbortHandle;
@@ -188,6 +189,7 @@ fn run_runtime(receiver: Receiver<Command>) {
188
189
// Use the IoUring driver explicitly to avoid ambiguity with feature combinations.
190
let mut rt = RuntimeBuilder::<IoUringDriver>::new()
191
.enable_timer()
192
+ .attach_thread_pool(Box::new(DefaultThreadPool::new(8)))
193
.build()
194
.expect("failed to build uring runtime");
195
0 commit comments