qubit-executor 0.1.0

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
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70

/*******************************************************************************
 *
 *    Copyright (c) 2025 - 2026.
 *    Haixing Hu, Qubit Co. Ltd.
 *
 *    All rights reserved.
 *
 ******************************************************************************/
use std::{
    io,
    sync::Arc,
};

use thiserror::Error;

/// Error returned when an executor service refuses to accept a task.
///
/// This error is about task acceptance only. It does not describe task
/// execution success or failure; accepted tasks report their final result
/// through the handle returned by the service.
///
/// # Author
///
/// Haixing Hu
#[derive(Debug, Clone, Error)]
pub enum RejectedExecution {
    /// The service has been shut down and no longer accepts new tasks.
    #[error("task rejected because the executor service is shut down")]
    Shutdown,

    /// The service is saturated and cannot accept more tasks.
    #[error("task rejected because the executor service is saturated")]
    Saturated,

    /// The service accepted the task conceptually but could not create the
    /// worker thread required to execute it.
    #[error("task rejected because the executor service failed to spawn a worker: {source}")]
    WorkerSpawnFailed {
        /// I/O error reported while spawning the worker.
        source: Arc<io::Error>,
    },
}

impl PartialEq for RejectedExecution {
    /// Compares rejection categories.
    ///
    /// Worker spawn failures compare equal by variant because [`io::Error`]
    /// does not provide value equality.
    ///
    /// # Parameters
    ///
    /// * `other` - Rejection value to compare with this value.
    ///
    /// # Returns
    ///
    /// `true` when both values have the same rejection category.
    fn eq(&self, other: &Self) -> bool {
        matches!(
            (self, other),
            (Self::Shutdown, Self::Shutdown)
                | (Self::Saturated, Self::Saturated)
                | (
                    Self::WorkerSpawnFailed { .. },
                    Self::WorkerSpawnFailed { .. }
                )
        )
    }
}

impl Eq for RejectedExecution {}