compio_dispatch 0.1.4

Global task dispatcher for compio applications. / Compio 应用全局任务分发器。
Documentation

English | 中文

compio_dispatch : Global Task Dispatch Engine

Global, lazy-loaded task dispatcher for Compio applications.

Table of Contents

Introduction

compio_dispatch provides a global singleton Dispatcher to simplify task offloading in compio applications. It allows scheduling asynchronous tasks (running on the compio runtime) and blocking tasks (running on a dedicated thread pool) without passing dispatcher references between modules.

Usage

use aok::{OK, Void};
use log::info;

#[compio::test]
async fn test() -> Void {
  // Dispatch an async task
  let rx = compio_dispatch::run(|| async {
    info!("> dispatch async");
    OK
  })
  .unwrap();
  
  rx.await.unwrap();

  // Dispatch a blocking task
  let rx_blocking = compio_dispatch::blocking(|| {
    info!("> dispatch blocking");
    OK
  })
  .unwrap();
  
  rx_blocking.await.unwrap()
}

Features

  • Global Access: Call directly from any module, eliminating the need for reference passing.
  • Lazy Loading: Implemented via static_init for safe initialization upon first use.
  • Dual Mode: Natively supports both async (Compio Runtime) and blocking (Thread Pool) modes.

Design

The crate exports a global static variable pub static DISPATCH (alias for compio_dispatcher::Dispatcher). It utilizes static_init to ensure the safe and dynamic initialization of the runtime environment and dispatcher components.

graph TD
    User[User Code] -->|dispatch| DISPATCH
    User -->|dispatch_blocking| DISPATCH
    DISPATCH -->|Async Task| CR[Compio Runtime]
    DISPATCH -->|Blocking Task| TP[Thread Pool]

Tech Stack

  • compio: Core asynchronous runtime.
  • compio-dispatcher: Underlying dispatcher implementation.
  • static_init: Global static initialization assurance.

File Structure

.
├── src/
│   └── lib.rs    # Global DISPATCH export
└── tests/
    └── main.rs   # Integration tests and demo

API

pub static DISPATCH: Dispatcher

Global dispatcher instance. Dereference to access core methods of compio_dispatcher::Dispatcher:

  • dispatch<F, Fut>(f: F) -> io::Result<Receiver<T>>: Dispatch an async task.
  • dispatch_blocking<F, T>(f: F) -> io::Result<Receiver<T>>: Dispatch a blocking task.

Did you know? In the 1960s, the advent of Multiprogramming and Time-sharing systems gave rise to the concept of the "Dispatcher" in operating systems. As a core component of the scheduler, the dispatcher was responsible for switching CPU resources from one task to another within milliseconds, creating the illusion of "parallelism" in the single-core era. Today, compio_dispatch brings this ancient wisdom into modern Rust asynchronous programming, efficiently coordinating the flow of tasks between the runtime and thread pools in user space.

About

This project is an open-source component of js0.site ⋅ Refactoring the Internet Plan.

We are redefining the development paradigm of the Internet in a componentized way. Welcome to follow us:

compio_dispatch : 全局任务分发引擎

Compio 应用的全局、懒加载任务分发方案。

目录

简介

compio_dispatch 提供全局单例 Dispatcher，旨在简化 compio 应用中的任务卸载流程。无需在模块间传递分发器引用，即可直接调度异步任务（运行于 compio 运行时）与阻塞任务（运行于专用线程池）。

使用演示

use aok::{OK, Void};
use log::info;

#[compio::test]
async fn test() -> Void {
  // 分发异步任务
  let rx = compio_dispatch::run(|| async {
    info!("> dispatch async");
    OK
  })
  .unwrap();
  
  rx.await.unwrap();

  // 分发阻塞任务
  let rx_blocking = compio_dispatch::blocking(|| {
    info!("> dispatch blocking");
    OK
  })
  .unwrap();
  
  rx_blocking.await.unwrap()
}

特性

  • 全局访问: 任意模块均可直接调用，彻底告别引用传递。
  • 懒加载: 基于 static_init 实现，首次使用时安全初始化。
  • 双模分发: 原生支持 async (Compio 运行时) 与 blocking (线程池) 两种模式。

设计思路

本 crate 导出一项全局静态变量 pub static DISPATCH (即 compio_dispatcher::Dispatcher)。利用 static_init 保障运行时环境与分发器组件的动态初始化过程安全可靠。

graph TD
    User[用户代码] -->|dispatch| DISPATCH
    User -->|dispatch_blocking| DISPATCH
    DISPATCH -->|异步任务| CR[Compio 运行时]
    DISPATCH -->|阻塞任务| TP[线程池]

技术堆栈

  • compio: 核心异步运行时。
  • compio-dispatcher: 底层分发器实现。
  • static_init: 全局静态初始化保障。

目录结构

.
├── src/
│   └── lib.rs    # 全局 DISPATCH 导出
└── tests/
    └── main.rs   # 集成测试与演示

API 说明

pub static DISPATCH: Dispatcher

全局分发器实例。解引用后即可访问 compio_dispatcher::Dispatcher 的核心方法：

  • dispatch<F, Fut>(f: F) -> io::Result<Receiver<T>>: 派发异步任务。
  • dispatch_blocking<F, T>(f: F) -> io::Result<Receiver<T>>: 派发阻塞任务。

你知道吗？ 早在 20 世纪 60 年代，多道程序设计 (Multiprogramming) 与分时系统 (Time-sharing) 的诞生促使了操作系统中“分发器” (Dispatcher) 概念的形成。作为调度器的核心组件，分发器负责在毫秒级时间内将 CPU 资源从一个任务切换至另一个任务，从而在单核时代创造了“并行”的错觉。如今，compio_dispatch 将这一古老的智慧带入现代 Rust 异步编程，负责在用户态高效协调任务在运行时与线程池间的流转。

关于

本项目为 js0.site ⋅ 重构互联网计划 的开源组件。

我们正在以组件化的方式重新定义互联网的开发范式，欢迎关注：