taskflowrs 0.1.1

A Rust implementation of TaskFlow — task-parallel programming with heterogeneous GPU support
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18

// Minimal pipeline example to test exports
fn main() {
    use taskflow_rs::pipeline::{ConcurrentPipeline, Token, StageType};
    
    println!("Testing pipeline exports...");
    
    let pipeline = ConcurrentPipeline::new(10, 100);
    pipeline.push(42).unwrap();
    
    if let Some(token) = pipeline.try_pop() {
        println!("Got token #{}: {}", token.index, token.data);
    }
    
    let stage = StageType::Serial;
    println!("Stage type: {:?}", stage);
    
    println!("✓ Pipeline exports work!");
}