From ec4528505e2a38bf27731b7898e3e62cfaae8f62 Mon Sep 17 00:00:00 2001 From: Bojan Serafimov Date: Tue, 14 Jun 2022 12:38:09 -0400 Subject: [PATCH] Simplify --- pageserver/src/tenant_threads.rs | 8 +------- 1 file changed, 1 insertion(+), 7 deletions(-) diff --git a/pageserver/src/tenant_threads.rs b/pageserver/src/tenant_threads.rs index 7f44552904..c4a83d00d0 100644 --- a/pageserver/src/tenant_threads.rs +++ b/pageserver/src/tenant_threads.rs @@ -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())); }, } }