import queue
import time
from dataclasses import dataclass, field, replace
from typing import Any, Dict, Tuple
use std::time::Duration;
use tokio_util::sync::CancellationToken;
pub struct Worker {
id: usize,
token: CancellationToken,
package main
import (
"context"
"log"
"net/http"
use tokio::sync::broadcast;
pub struct Shutdown {
is_shutdown: bool,
notify: broadcast::Receiver<()>,
}