any_spawner 0.3.0

Spawn asynchronous tasks in an executor-independent way.
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
46
47
48
49
50
51
52
53
54

use any_spawner::Executor;
use std::sync::{
    atomic::{AtomicBool, Ordering},
    Arc,
};

#[test]
fn test_local_custom_executor() {
    // Define a thread-local custom executor
    struct LocalTestExecutor {
        spawn_called: Arc<AtomicBool>,
        spawn_local_called: Arc<AtomicBool>,
    }

    impl any_spawner::CustomExecutor for LocalTestExecutor {
        fn spawn(&self, fut: any_spawner::PinnedFuture<()>) {
            self.spawn_called.store(true, Ordering::SeqCst);
            futures::executor::block_on(fut);
        }

        fn spawn_local(&self, fut: any_spawner::PinnedLocalFuture<()>) {
            self.spawn_local_called.store(true, Ordering::SeqCst);
            futures::executor::block_on(fut);
        }

        fn poll_local(&self) {
            // No-op for this test
        }
    }

    let local_spawn_called = Arc::new(AtomicBool::new(false));
    let local_spawn_local_called = Arc::new(AtomicBool::new(false));

    let local_executor = LocalTestExecutor {
        spawn_called: local_spawn_called.clone(),
        spawn_local_called: local_spawn_local_called.clone(),
    };

    // Initialize a thread-local executor
    Executor::init_local_custom_executor(local_executor)
        .expect("Failed to initialize local custom executor");

    // Test spawn - should use the thread-local executor
    Executor::spawn(async {
        // Simple task
    });
    assert!(local_spawn_called.load(Ordering::SeqCst));

    // Test spawn_local - should use the thread-local executor
    Executor::spawn_local(async {
        // Simple local task
    });
    assert!(local_spawn_local_called.load(Ordering::SeqCst));
}