rust/neon
1
0
Fork 0
mirror of https://github.com/neondatabase/neon.git synced 2026-01-16 01:42:55 +00:00
Code Issues Packages Projects Releases Wiki Activity

hack: use a single runtime in pageserver

Browse Source 
doesn't seem to make a meaningful perf difference under
get-page-latest-lsn load
This commit is contained in:
Christian Schwarz
2024-01-29 12:23:25 +00:00
parent 87e501a273
commit 9f24321d13
1 changed files with 25 additions and 21 deletions
Download Patch File Download Diff File Expand all files Collapse all files

46
pageserver/src/task_mgr.rs
View File

@@ -104,29 +104,29 @@ use crate::shutdown_pageserver;
// other operations, if the upload tasks e.g. get blocked on locks. It shouldn't
// happen, but still.
//
pub static COMPUTE_REQUEST_RUNTIME: Lazy<Runtime> = Lazy::new(|| {
tokio::runtime::Builder::new_multi_thread()
.thread_name("compute request worker")
.enable_all()
.build()
.expect("Failed to create compute request runtime")
});
// pub static COMPUTE_REQUEST_RUNTIME: Lazy<Runtime> = Lazy::new(|| {
// tokio::runtime::Builder::new_multi_thread()
// .thread_name("compute request worker")
// .enable_all()
// .build()
// .expect("Failed to create compute request runtime")
// });
pub static MGMT_REQUEST_RUNTIME: Lazy<Runtime> = Lazy::new(|| {
tokio::runtime::Builder::new_multi_thread()
.thread_name("mgmt request worker")
.enable_all()
.build()
.expect("Failed to create mgmt request runtime")
});
// pub static MGMT_REQUEST_RUNTIME: Lazy<Runtime> = Lazy::new(|| {
// tokio::runtime::Builder::new_multi_thread()
// .thread_name("mgmt request worker")
// .enable_all()
// .build()
// .expect("Failed to create mgmt request runtime")
// });
pub static WALRECEIVER_RUNTIME: Lazy<Runtime> = Lazy::new(|| {
tokio::runtime::Builder::new_multi_thread()
.thread_name("walreceiver worker")
.enable_all()
.build()
.expect("Failed to create walreceiver runtime")
});
// pub static WALRECEIVER_RUNTIME: Lazy<Runtime> = Lazy::new(|| {
// tokio::runtime::Builder::new_multi_thread()
// .thread_name("walreceiver worker")
// .enable_all()
// .build()
// .expect("Failed to create walreceiver runtime")
// });
pub static BACKGROUND_RUNTIME: Lazy<Runtime> = Lazy::new(|| {
tokio::runtime::Builder::new_multi_thread()
@@ -150,6 +150,10 @@ pub(crate) static BACKGROUND_RUNTIME_WORKER_THREADS: Lazy<usize> = Lazy::new(||
.unwrap_or_else(|_e| usize::max(2, num_cpus::get()))
});
pub static COMPUTE_REQUEST_RUNTIME: &once_cell::sync::Lazy<Runtime> = &BACKGROUND_RUNTIME;
pub static MGMT_REQUEST_RUNTIME: &once_cell::sync::Lazy<Runtime> = &BACKGROUND_RUNTIME;
pub static WALRECEIVER_RUNTIME: &once_cell::sync::Lazy<Runtime> = &BACKGROUND_RUNTIME;
#[derive(Debug, Clone, Copy)]
pub struct PageserverTaskId(u64);