#ifndef MANY_TO_MANY_SCHEDULER_HPP
#define MANY_TO_MANY_SCHEDULER_HPP

typedef void (*ManyToManyPipeTaskFunction)(int taskId,
                                           int workerId,
                                           int workerCount,
                                           void* ctx);

int run_many_to_many_pipe_scheduler(int taskCount,
                                    int workerCount,
                                    ManyToManyPipeTaskFunction taskFn,
                                    void* ctx,
                                    bool useAffinity);

#endif