A cleaner way to limit tokio spawn than a tokio::sync::Semaphore

[doubleailes]

Hello,

I would like to limit the number of spawn thread when using tokio executor.

I end up using

 let semaphore = Arc::new(Semaphore::new(32));
    consumer.set_delegate(move |delivery: DeliveryResult| {
        let semaphore_clone = Arc::clone(&semaphore);
        async move {
            let _permit = semaphore_clone.acquire().await;
        ....}

Is there a cleaner to deal with it?