threading_tbb Namespace Reference

Namespaces
	this_task_arena

Classes
struct	tbb_packaged_task
struct	tbb_packaged_task< void >
struct	future
struct	future< void >

Functions
template<typename... X>
void	parallel_for (X &&...x)
template<typename... X>
auto	parallel_reduce (X &&...x) -> decltype(tbb::parallel_reduce(std::forward< X >(x)...))
template<typename Fn , typename... Args, typename Result = std::result_of_t<Fn && (Args && ...)>>
future< Result >	async (Fn &&fn, Args &&...args)

Variables
tbb::task_arena	g_tbb_arena

Function Documentation

template<typename Fn , typename... Args, typename Result = std::result_of_t<Fn && (Args && ...)>>

future<Result> threading_tbb::async	(	Fn &&	fn,
		Args &&...	args
	)

Definition at line 73 of file threading_tbb.h.

References run_benchmark_import::args, f(), and g_tbb_arena.

                                              {
  auto f = std::bind(std::forward<Fn>(fn), std::forward<Args>(args)...);
  auto ptask = std::make_unique<tbb_packaged_task<Result>>();
#if TBB_INTERFACE_VERSION >= 12040
  g_tbb_arena.enqueue(ptask->defer(f));
#else
  g_tbb_arena.execute([&] { ptask->run(f); });
#endif
  return future<Result>(std::move(ptask));
}

Here is the call graph for this function:

template<typename... X>

void threading_tbb::parallel_for

(

X &&...

x

)

Definition at line 20 of file threading_tbb.h.

References g_tbb_arena, and threading_serial::parallel_for().

                            {
  g_tbb_arena.execute([&] {
    this_task_arena::isolate([&] { tbb::parallel_for(std::forward<X>(x)...); });
  });
}

Here is the call graph for this function:

template<typename... X>

auto threading_tbb::parallel_reduce

(

X &&...

x

)

-> decltype(tbb::parallel_reduce(std::forward<X>(x)...))

Definition at line 27 of file threading_tbb.h.

References g_tbb_arena, and threading_serial::parallel_reduce().

                                                                                    {
  return g_tbb_arena.execute([&] {
    return this_task_arena::isolate(
        [&] { return tbb::parallel_reduce(std::forward<X>(x)...); });
  });
}

Here is the call graph for this function:

Variable Documentation

tbb::task_arena threading_tbb::g_tbb_arena

Referenced by async(), parallel_for(), parallel_reduce(), startHeavyDBServer(), threading_tbb::future< T >::wait(), and threading_tbb::future< void >::wait().