Function async_queue

crates/create-rust-app/src/tasks/mod.rs:36–42

Returns a reference to the async queue. Tasks scheduled in this queue will be executed by the async queue process. An async queue process can be started by running the `async_queue` binary (this is the default for newly generated projects). Make sure you connect this queue to your db at the start of your app: ```rust let queue = async_queue(); queue.lock().unwrap().connect(NoTls).await.expect("F

()

///    queue.lock().unwrap().connect(NoTls).await.expect("Failed to connect to queue DB");
/// ```
pub fn async_queue() -> &'static Mutex<AsyncQueue<NoTls>> {
    static ASYNC_QUEUE: OnceCell<Mutex<AsyncQueue<NoTls>>> = OnceCell::new();

    ASYNC_QUEUE.get_or_init(|| {
        Mutex::new(create_async_queue(10 /* r2d2's default */))
    })
}

/// Creates a new async queue with the specified max pool size.
/// You should not need to use this function directly.