qubit-executor 0.5.2

Executor abstractions, task handles, and basic executor implementations for Qubit Rust libraries
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

/*******************************************************************************
 *
 *    Copyright (c) 2025 - 2026 Haixing Hu.
 *
 *    SPDX-License-Identifier: Apache-2.0
 *
 *    Licensed under the Apache License, Version 2.0.
 *
 ******************************************************************************/
use std::{
    io,
    sync::{
        Arc,
        atomic::Ordering,
    },
};

use qubit_atomic::Atomic;
use qubit_executor::executor::{
    DirectExecutor,
    Executor,
};

/// Test the default runnable execution method on the executor trait.
#[test]
fn test_executor_execute_default_delegates_to_call() {
    let executor = DirectExecutor::new();
    let calls = Arc::new(Atomic::new(0usize));
    let calls_for_task = Arc::clone(&calls);

    executor
        .execute(move || {
            calls_for_task.fetch_add_with_ordering(1, Ordering::AcqRel);
            Ok::<(), io::Error>(())
        })
        .expect("direct executor should accept the runnable")
        .get()
        .expect("direct executor should run the runnable");

    assert_eq!(calls.load(), 1);
}