qubit-task 0.3.0

Task-oriented services built on top of qubit-executor and qubit-thread-pool
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

/*******************************************************************************
 *
 *    Copyright (c) 2025 - 2026 Haixing Hu.
 *
 *    SPDX-License-Identifier: Apache-2.0
 *
 *    Licensed under the Apache License, Version 2.0.
 *
 ******************************************************************************/
//! Tests for [`TaskExecutionServiceBuilder`](qubit_task::service::TaskExecutionServiceBuilder).

use std::time::Duration;

use qubit_task::service::{
    ExecutorServiceBuilderError,
    TaskExecutionService,
    TaskExecutionServiceBuilder,
    ThreadPool,
};

#[test]
fn test_task_execution_service_builder_builds_default_service() {
    let service = TaskExecutionServiceBuilder::default()
        .build()
        .expect("default builder should create service");

    assert!(!service.is_not_running());
    assert!(service.thread_pool().maximum_pool_size() > 0);
    service.shutdown();
    service.wait_termination();
}

#[test]
fn test_task_execution_service_builder_applies_thread_pool_builder() {
    let service = TaskExecutionService::builder()
        .thread_pool(
            ThreadPool::builder()
                .pool_size(2)
                .queue_capacity(3)
                .keep_alive(Duration::from_millis(25)),
        )
        .build()
        .expect("custom pool builder should create service");

    assert_eq!(service.thread_pool().maximum_pool_size(), 2);
    assert_eq!(service.thread_pool().stats().queued_tasks, 0);
    service.shutdown();
    service.wait_termination();
}

#[test]
fn test_task_execution_service_builder_returns_pool_build_error() {
    let result = TaskExecutionService::builder()
        .thread_pool(ThreadPool::builder().pool_size(0))
        .build();

    assert!(matches!(
        result,
        Err(ExecutorServiceBuilderError::ZeroMaximumPoolSize),
    ));
}