smol-rs/smol
Smol
Smol is a lightweight Rust asynchronous runtime and task executor. It provides a suite of foundational tools for scheduling and executing asynchronous futures, managing background workloads, and handling non-blocking network and file operations.
The project includes a compatibility layer for adapting asynchronous types and execution contexts, enabling futures to run across different runtime ecosystems. It also features a mechanism to offload synchronous I/O and CPU-intensive operations to dedicated worker thread pools to prevent runtime stalls.
Its capabilities cover non-blocking network I/O for TCP, UDP, and Unix connections, as well as asynchronous filesystem operations and system process management. For coordinating shared state, it provides a suite of concurrency primitives including asynchronous mutexes, semaphores, and channels. Additional functionality includes timed event scheduling for delayed or recurring tasks.
Features
- Async I/O Runtimes - Acts as a lightweight async runtime providing the core event loop and task scheduler for Rust applications.
- Blocking Task Offloaders - Provides mechanisms to offload synchronous CPU-intensive tasks to dedicated thread pools.
- Waker-Based Schedulers - Implements a task executor that manages future progression using the standard library waker mechanism.
- Non-Blocking Socket I/O - Ships non-blocking socket I/O for handling multiple TCP and UDP streams asynchronously.
- Asynchronous I/O Libraries - Provides a comprehensive library of non-blocking interfaces for system I/O operations.
- Non-Blocking I/O Interfaces - Implements non-blocking I/O interfaces that monitor multiple network sockets and files via OS event notifications.
- Asynchronous File Access - Provides non-blocking utilities for reading and writing files on the local filesystem.
- Asynchronous Runtime Adapters - Provides abstraction layers that enable asynchronous futures to operate across different runtime implementations.
- Concurrency Primitives - Implements essential synchronization constructs such as asynchronous mutexes, semaphores, and channels.
- Asynchronous Runtime Compatibility - Offers a compatibility layer for detecting and utilizing event loops to execute tasks across different runtimes.
- Async-Sync Compatibility Layers - Provides architectural mechanisms to ensure interoperability between different asynchronous runtime ecosystems.
- Asynchronous File I/O - Provides non-blocking interfaces for reading and writing files to prevent runtime stalls.
- Asynchronous Schedulers - Implements an asynchronous scheduler that maps computational tasks to thread pools for non-blocking execution.
- Asynchronous Task Executors - Ships a task executor that schedules and runs asynchronous futures on global or local thread pools.
- Event-Driven I/O - Implements event-driven I/O to handle TCP, UDP, and Unix connections asynchronously.
- Process Management - Provides interfaces for interacting with system processes while maintaining application responsiveness.
- External Process Management - Enables spawning and controlling external system processes using non-blocking communication.
- Blocking I/O Offloading - Includes a utility to offload synchronous I/O operations to a dedicated thread pool to prevent runtime stalls.
- Trait Adaptation Layers - A utility for converting asynchronous input and output traits between different ecosystems to ensure compatibility across various libraries.
- Blocking Operation Handlers - Offloads synchronous I/O and CPU-intensive computations to worker threads to maintain runtime responsiveness.
- Thread Pools - Manages a collection of worker threads to handle synchronous I/O and CPU-heavy operations.
- Timer Schedulers - Includes interfaces for scheduling asynchronous tasks using delayed timeouts and recurring intervals.
- Asynchronous Synchronization Primitives - Provides a suite of asynchronous mutexes and semaphores to coordinate access to shared state.
- Scoped Task Synchronization - Implements mechanisms to coordinate the completion of parallel operations and resource access.
- Message Passing Channels - Provides synchronized communication primitives for exchanging data between concurrent asynchronous tasks.
