#ifndef MANY_TO_MANY_PIPE_SCHEDULER_HPP
#define MANY_TO_MANY_PIPE_SCHEDULER_HPP

#include "bounded_prolific_scheduler.hpp"

int run_many_to_many_pipe_scheduler(
    int totalTasks, 
    int workerCount,
    scheduler_task_fn taskFn,
    void* context,
    bool enableAffinity = false
                    );


#endif