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

Simplify

Browse Source
This commit is contained in:
Bojan Serafimov
2022-06-14 12:38:09 -04:00
parent c79e72e835
commit ec4528505e
1 changed files with 1 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
pageserver/src/tenant_threads.rs
View File

@@ -80,17 +80,11 @@ pub fn init_tenant_task_pool() -> Result<()> {
true,
move || {
runtime.block_on(async move {
let mut futures = FuturesUnordered::new();
loop {
tokio::select! {
_ = thread_mgr::shutdown_watcher() => break,
tenantid = recv.recv() => {
let tenantid = tenantid.unwrap();
// Await concurrently with all other futures
futures.push(tokio::spawn(gc_loop(tenantid)));
},
_ = futures.next() => {
// Do nothing. We're waiting on them just to make progress
tokio::spawn(gc_loop(tenantid.unwrap()));
},
}
}