dtact 0.1.5

Dtact: A non-preemptive, stackful coroutine runtime featuring a lock-free context arena, P2P mesh scheduling, and architecture-specific assembly switchers. Designed for hardware-level control and non-blocking heterogeneous orchestration.
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
55
56
57
58
59
60
61

use dtact::FiberStatus;
use loom::sync::Arc;
use loom::sync::atomic::{AtomicU8, Ordering};
use loom::thread;

struct MockFiberContext {
    state: AtomicU8,
}

#[cfg_attr(miri, ignore)]
#[test]
fn test_fiber_state_transitions() {
    loom::model(|| {
        let ctx = Arc::new(MockFiberContext {
            state: AtomicU8::new(FiberStatus::Initial as u8),
        });

        // Simulating dispatch loop picking it up
        ctx.state
            .store(FiberStatus::Running as u8, Ordering::Release);

        let ctx_clone = ctx.clone();

        // Waker thread
        let waker = thread::spawn(move || {
            // Simulated wake_by_ref_impl
            let prev = ctx_clone
                .state
                .swap(FiberStatus::Notified as u8, Ordering::AcqRel);
            if prev == FiberStatus::Yielded as u8 {
                // Enqueue
            }
        });

        // wait_pinned thread
        let waiter = thread::spawn(move || {
            // Simulating a loop iteration
            ctx.state
                .store(FiberStatus::Running as u8, Ordering::Release);

            // Simulating poll returning Pending

            // Try to suspend
            if ctx
                .state
                .compare_exchange(
                    FiberStatus::Running as u8,
                    FiberStatus::Yielded as u8,
                    Ordering::Release,
                    Ordering::Acquire,
                )
                .is_ok()
            {
                // suspended
            }
        });

        waker.join().unwrap();
        waiter.join().unwrap();
    });
}