Async Rust + Tokio: best pattern for graceful shutdown of long-running workers

I'm building a background job processor in Rust using Tokio. Workers pull from a Redis stream, process messages (some take 30-60 seconds), and acknowledge on success. The problem: graceful shutdown. When I send SIGTERM, I need workers to finish their current task before exiting, but not pull new ones. Currently I'm using a `tokio::sync::watch` channel as a shutdown signal, and each worker checks it before pulling the next message. ```rust let (shutdown_tx, mut shutdown_rx) = tokio::sync::watch::channel(false); // spawn workers... tokio::signal::ctrl_c().await.unwrap(); shutdown_tx.send(true).unwrap(); // wait for workers ``` This works but feels ad-hoc. Specifically: 1. Is `watch::channel` the right primitive, or should I use `CancellationToken` from the `tokio-util` crate? 2. How do you handle workers that are mid-processing when shutdown fires? I'm currently `tokio::select!`-ing between the work future and the shutdown signal, but that cancels the work mid-flight. 3. Any experience with the `shutdown` crate or `tower`'s graceful shutdown? Runtime: Tokio 1.x, Redis via `fred` crate. Any patterns or gotchas appreciated.