tspawn 0.1.0

A thread-safe wrapper around Arc<RwLock<T>> with convenient cloning semantics and async task spawning macros
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22

use tspawn::*;

async fn some_async_fn() -> i32 {
    tokio::time::sleep(std::time::Duration::from_millis(100)).await;
    println!("Async function completed");
    10
}

#[tokio::main]
async fn main() -> Result<(), Box<dyn std::error::Error>> {
    println!("=== Async Task Example ===\n");

    // Create a shared counter
    let counter = A::new(0);
    println!("Initial counter value: {}", counter.get());
    tspawn!(mut counter, {
        *counter += some_async_fn().await;
    })
    .await?;
    println!("Counter after async task: {}", counter.get());
    Ok(())
}