1 unstable release
new 0.1.0 | Nov 2, 2024 |
---|
#272 in Concurrency
73KB
1K
SLoC
Disruptor-rs
A heavily documented Rust implementation of the LMAX Disruptor pattern, focused on high-performance inter-thread messaging.
Origins & Purpose
This project is a fork of disrustor by Sebastian Klose. While the original implementation provided an excellent foundation, this fork aims to:
- Provide comprehensive documentation explaining the Disruptor pattern
- Rewrite the implementation in a more idiomatic Rust style
- Create a production-ready, Rust-native package for the community
What is the Disruptor?
The Disruptor is a high-performance inter-thread messaging library, originally developed by LMAX Exchange for their financial trading platform. It achieves superior performance through:
- Lock-free algorithms
- Cache-line padding to prevent false sharing
- Efficient memory pre-allocation
- Mechanical sympathy with modern CPU architectures
Key Components
1. Ring Buffer
A fixed-size circular buffer that pre-allocates memory for events:
- Zero garbage collection
- Cache-friendly memory access patterns
- Power-of-2 sizing for efficient modulo operations
2. Sequences
Cache-line padded atomic counters that track:
- Producer position in the ring buffer
- Consumer progress
- Dependencies between consumers
3. Sequencer
Coordinates access to the ring buffer:
- Manages sequence claim and publication
- Implements backpressure
- Ensures thread-safety
4. Event Processing
- Producers: Write events to the ring buffer
- Consumers: Process events through user-defined handlers
- Barriers: Coordinate dependencies between processors
5. Waiting Strategies
Different strategies for thread coordination:
BusySpinWaitStrategy
: Lowest latency, highest CPU usageYieldingWaitStrategy
: Balanced approachSleepingWaitStrategy
: Lowest CPU usage, higher latency
Usage Example
use disruptor_rs::{DisruptorBuilder, EventHandler};
// Define your event type
#[derive(Default)]
struct MyEvent {
data: i64,
}
// Define your event handler
#[derive(Default)]
struct MyHandler;
impl EventHandler<MyEvent> for MyHandler {
fn on_event(&self, event: &MyEvent, sequence: i64, end_of_batch: bool) {
println!("Processing event: {} at sequence {}", event.data, sequence);
}
}
// Build and run the disruptor
let (executor, producer) = DisruptorBuilder::with_ring_buffer::<MyEvent>(1024)
.with_busy_spin_waiting_strategy()
.with_single_producer_sequencer()
.with_barrier(|scope| {
scope.handle_events(MyHandler::default());
})
.build();
// Start processing
let handle = executor.spawn();
// Produce events
// ...
// Cleanup
producer.drain();
handle.join();
Performance Considerations
- Ring Buffer Size: Must be a power of 2
- Waiting Strategy: Choose based on your latency/CPU trade-offs
- Event Handlers: Keep processing logic lightweight
- Batch Processing: Use batch writes when possible
Contributing
Contributions are welcome! Please feel free to submit a Pull Request. Areas of interest:
- Additional waiting strategies
- Performance optimizations
- Documentation improvements
- Example use cases
License
This project is licensed under the MIT License - see the LICENSE file for details.
Acknowledgments
- Original implementation by Sebastian Klose
- LMAX team for the original Java implementation
Dependencies
~8–18MB
~253K SLoC