console-subscriber 0.4.1

A `tracing-subscriber::Layer` for collecting Tokio console telemetry.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45

use std::sync::Arc;
use std::time::Duration;
use tokio::task;

#[tokio::main]
async fn main() -> Result<(), Box<dyn std::error::Error + Send + Sync>> {
    console_subscriber::init();
    task::Builder::default()
        .name("main-task")
        .spawn(async move {
            let sem = Arc::new(tokio::sync::Semaphore::new(0));
            let mut tasks = Vec::default();
            for i in 0..5 {
                let acquire_sem = Arc::clone(&sem);
                let add_sem = Arc::clone(&sem);
                let acquire_task_name = format!("acquire-{}", i);
                let add_task_name = format!("add-{}", i);
                tasks.push(
                    tokio::task::Builder::default()
                        .name(&acquire_task_name)
                        .spawn(async move {
                            let _permit = acquire_sem.acquire_many(i).await.unwrap();
                            tokio::time::sleep(Duration::from_secs(i as u64 * 2)).await;
                        })
                        .unwrap(),
                );
                tasks.push(
                    tokio::task::Builder::default()
                        .name(&add_task_name)
                        .spawn(async move {
                            tokio::time::sleep(Duration::from_secs(i as u64 * 5)).await;
                            add_sem.add_permits(i as usize);
                        })
                        .unwrap(),
                );
            }

            let all_tasks = futures::future::try_join_all(tasks);
            all_tasks.await.unwrap();
        })
        .unwrap()
        .await?;

    Ok(())
}