#ifndef ONE_TO_ONE_PIPE_SCHEDULER_HPP
#define ONE_TO_ONE_PIPE_SCHEDULER_HPP

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

int run_one_to_one_pipe_scheduler(int taskCount,
                                  int workerCount,
                                  OneToOnePipeTaskFunction taskFn,
                                  void* ctx,
                                  bool useAffinity);

#endif