#ifndef ONE_TO_MANY_SCHEDULER_HPP
#define ONE_TO_MANY_SCHEDULER_HPP

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

int run_one_to_many_pipe_scheduler(int taskCount,
                                   int workerCount,
                                   OneToManyPipeTaskFunction taskFn,
                                   void* ctx,
                                   bool useAffinity);

#endif