#run-time #engine #execution #management #optimization #scheduling #fluxus-runtime

fluxus-runtime

Runtime implementation for Fluxus stream processing engine

4 releases

Uses new Rust 2024

new 0.1.3 Apr 24, 2025
0.1.2 Apr 24, 2025
0.1.1 Apr 23, 2025
0.1.0 Apr 23, 2025

#11 in #scheduling

Download history 138/week @ 2025-04-17

140 downloads per month
Used in 2 crates

Apache-2.0

79KB
1.5K SLoC

Fluxus Runtime

Runtime engine and execution environment for the Fluxus stream processing engine.

Overview

This crate provides the execution environment and runtime components for Fluxus:

  • Task execution and scheduling
  • Memory management
  • Threading and concurrency
  • Performance optimization
  • Resource management

Key Components

Task Execution

  • Parallel task execution
  • Work stealing scheduler
  • Back-pressure handling
  • Resource-aware scheduling

Threading Model

  • Thread pool management
  • Thread-safe data structures
  • Lock-free algorithms
  • Efficient inter-thread communication

Memory Management

  • Buffer management
  • Memory pooling
  • Efficient data serialization
  • Zero-copy optimizations

Monitoring

  • Performance metrics
  • Resource usage tracking
  • Runtime statistics
  • Diagnostics (planned)

Usage

Add this to your Cargo.toml:

[dependencies]
fluxus-runtime = "0.1"

This crate is usually not used directly but through the fluxus-api crate.

Dependencies

~6–15MB
~141K SLoC