_async | WorkDispatcher< I, O, Of, Ip, Op > | protected |
_devices | WorkDispatcher< I, O, Of, Ip, Op > | protected |
_do_work | WorkDispatcher< I, O, Of, Ip, Op > | protected |
_postprocess | WorkDispatcher< I, O, Of, Ip, Op > | protected |
_preprocess | WorkDispatcher< I, O, Of, Ip, Op > | protected |
_qmutex | WorkDispatcher< I, O, Of, Ip, Op > | protected |
_reduce | WorkDispatcher< I, O, Of, Ip, Op > | protected |
_results | WorkDispatcher< I, O, Of, Ip, Op > | protected |
_scheduler | WorkDispatcher< I, O, Of, Ip, Op > | protected |
_stop | WorkDispatcher< I, O, Of, Ip, Op > | protected |
_tasks | WorkDispatcher< I, O, Of, Ip, Op > | protected |
_thread_condition | WorkDispatcher< I, O, Of, Ip, Op > | protected |
_thread_init | WorkDispatcher< I, O, Of, Ip, Op > | protected |
_thread_pool | WorkDispatcher< I, O, Of, Ip, Op > | protected |
init_thread_pool() | WorkDispatcher< I, O, Of, Ip, Op > | protected |
operator=(WorkDispatcher &&)=delete | WorkDispatcher< I, O, Of, Ip, Op > | |
operator=(const WorkDispatcher &)=delete | WorkDispatcher< I, O, Of, Ip, Op > | |
run(WorkGenerator< Ip > &) | WorkDispatcher< I, O, Of, Ip, Op > | |
run_async(WorkGenerator< Ip > &) | WorkDispatcher< I, O, Of, Ip, Op > | protected |
run_sync(WorkGenerator< Ip > &) | WorkDispatcher< I, O, Of, Ip, Op > | protected |
should_unlock_thread() | WorkDispatcher< I, O, Of, Ip, Op > | protected |
stop_thread_pool() | WorkDispatcher< I, O, Of, Ip, Op > | protected |
thread_pool_main(const Device &) | WorkDispatcher< I, O, Of, Ip, Op > | protected |
validate() const | WorkDispatcher< I, O, Of, Ip, Op > | protected |
WorkDispatcher(WorkScheduler &scheduler, bool async, std::function< O(I &&, Device)> &&do_work) | WorkDispatcher< I, O, Of, Ip, Op > | inline |
WorkDispatcher(WorkScheduler &scheduler, bool async, std::function< O(I &&, Device)> &&do_work, std::function< O(std::vector< O > &&)> &&reduce) | WorkDispatcher< I, O, Of, Ip, Op > | inline |
WorkDispatcher(WorkScheduler &scheduler, bool async, std::function< O(I &&, Device)> &&do_work, std::function< Of(std::vector< Op > &&)> &&reduce, std::function< I(Ip &&, Device)> &&preprocess, std::function< Op(O &&)> &&postprocess) | WorkDispatcher< I, O, Of, Ip, Op > | inline |
WorkDispatcher(WorkScheduler &scheduler, bool async, std::function< O(I &&, Device)> &&do_work, std::function< Of(std::vector< Op > &&)> &&reduce, std::function< I(Ip &&, Device)> &&preprocess, std::function< Op(O &&)> &&postprocess, std::function< void(Device)> &&thread_init) | WorkDispatcher< I, O, Of, Ip, Op > | inline |
WorkDispatcher()=delete | WorkDispatcher< I, O, Of, Ip, Op > | |
WorkDispatcher(WorkDispatcher &&)=delete | WorkDispatcher< I, O, Of, Ip, Op > | |
WorkDispatcher(const WorkDispatcher &)=delete | WorkDispatcher< I, O, Of, Ip, Op > | |
~WorkDispatcher() | WorkDispatcher< I, O, Of, Ip, Op > | inline |