Home
last modified time | relevance | path

Searched refs:func (Results 1 – 25 of 29) sorted by relevance

12

/oneTBB/python/tbb/
H A Dpool.py99 def apply(self, func, args=(), kwds=dict()): argument
102 return self.apply_async(func, args, kwds).get()
104 def map(self, func, iterable, chunksize=None): argument
112 return self.map_async(func, iterable, chunksize).get()
114 def imap(self, func, iterable, chunksize=1): argument
132 def imap_unordered(self, func, iterable, chunksize=1): argument
152 job = Job(func, args, kwds, apply_result)
187 def imap_unordered_async(self, func, iterable, chunksize=None, argument
257 job = Job(func, (arg,), {}, apply_result)
269 def __init__(self, func, args, kwds, apply_result): argument
[all …]
H A Dtest.py96 def check_timeout_exception(pool_object, func): argument
99 func(pool_object)
/oneTBB/test/common/
H A Dparallel_reduce_common.h43 ResultType reduce_invoker(const Range& range, const Func& func, const Reduction& reduction, Partiti… in reduce_invoker() argument
44 return tbb::parallel_reduce( range, ResultType(), func, reduction, partiotioner ); in reduce_invoker()
48 ResultType reduce_invoker(const Range& range, const Func& func, const Reduction& reduction, utils_d… in reduce_invoker() argument
49 return tbb::parallel_reduce( range, ResultType(), func, reduction ); in reduce_invoker()
63 ResultType deterministic_reduce_invoker(const Range& range, const Func& func, in deterministic_reduce_invoker() argument
65 return tbb::parallel_deterministic_reduce( range, ResultType(), func, reduction, partiotioner ); in deterministic_reduce_invoker()
69 ResultType deterministic_reduce_invoker(const Range& range, const Func& func, in deterministic_reduce_invoker() argument
71 return tbb::parallel_deterministic_reduce( range, ResultType(), func, reduction ); in deterministic_reduce_invoker()
H A Dutils_dynamic_libs.h109 void GetAddress(utils::LIBRARY_HANDLE lib, const char *name, FunctionPointer& func) in GetAddress() argument
112 func = (FunctionPointer)(void*)GetProcAddress(lib, name); in GetAddress()
114 func = (FunctionPointer)dlsym(lib, name); in GetAddress()
116 REQUIRE_MESSAGE(func, "Can't find required symbol in dynamic library"); in GetAddress()
121 FunctionAddress func; in GetAddress() local
122 GetAddress(lib, name, func); in GetAddress()
123 return func; in GetAddress()
H A Dutils_report.h104 Tracer* set_trace_info( int flags, const char *file, std::size_t line, const char *func ) { in set_trace_info() argument
108 m_func = func; in set_trace_info()
H A Dgraph_utils.h134 static inline OutputType func( InputType v ) {
151 return func(v);
162 return harness_graph_executor::func(i);
188 static inline void func( const InputType &v, ports_type &p ) {
202 func(v,p);
213 harness_graph_multifunction_executor::func(i,p);
/oneTBB/examples/parallel_for/tachyon/src/
H A Dui.cpp62 void set_rt_ui_message(void (*func)(int, const char *)) { in set_rt_ui_message()
63 rt_static_ui_message = func; in set_rt_ui_message()
66 void set_rt_ui_progress(void (*func)(int)) { in set_rt_ui_progress()
67 rt_static_ui_progress = func; in set_rt_ui_progress()
/oneTBB/examples/graph/fgbzip2/
H A Dbzlib.hpp129 #define BZ_API(func) WINAPI func argument
133 #define BZ_API(func) (WINAPI * func) argument
137 #define BZ_API(func) func argument
/oneTBB/include/oneapi/tbb/
H A Dcollaborative_call_once.h55 auto func = [f] { in alignas()
61 delegated_function<decltype(func)> delegate(func); in alignas()
216 auto func = [&] { call(std::forward<Fn>(fn), std::move(stored_pack)); }; in collaborative_call_once()
218 auto func = [&] { fn(std::forward<Args>(args)...); }; in collaborative_call_once()
220 flag.do_collaborative_call_once(func); in collaborative_call_once()
H A Dtask_arena.h203 task_arena_function<F, R> func(f); in isolate_impl()
204 r1::isolate_within_arena(func, /*isolation*/ 0); in isolate_impl()
205 return func.consume_result(); in isolate_impl()
250 task_arena_function<F, R> func(f); in execute_impl()
251 r1::execute(*this, func); in execute_impl()
252 return func.consume_result(); in execute_impl()
H A Dtask_group.h660 F& func; variable
662 status = tg.run_and_wait(func); in operator()
667 : wait_delegate(a_group, tgs), func(a_func) {} in run_wait_delegate()
H A Dconcurrent_queue.h330 d1::delegated_function<FuncType> func(pred); in internal_wait()
331 r1::wait_bounded_queue_monitor(monitors, monitor_tag, target, func); in internal_wait()
/oneTBB/test/tbb/
H A Dtest_collaborative_call_once.cpp88 auto func = [&] { tbb::detail::d0::call(std::forward<Fn>(body), std::move(stored_pack)); }; in call_once_in_parallel_for() local
94 tbb::collaborative_call_once(flag, func); in call_once_in_parallel_for()
109 auto func = [&] { tbb::detail::d0::call(std::forward<Fn>(body), std::move(stored_pack)); }; in call_once_threads() local
116 tbb::collaborative_call_once(flag, func); in call_once_threads()
185 auto func = [&ready, &value] (move_only_type other) { in __anon8532fc100502() variable
193 call_once_in_parallel_for(512, func, std::move(mv));
202 call_once_threads(utils::get_platform_max_threads(), func, std::move(mv));
H A Dtest_parallel_invoke.cpp89 void func() { func_counter++; }; in func() function
94 auto func_ptr = &func;
H A Dtest_function_node.cpp234 …( InputType i ) -> OutputType { return harness_graph_executor<InputType, OutputType>::func(i); } ); in run_buffered_levels()
235 … buffered_levels<InputType,OutputType>( c, &harness_graph_executor<InputType, OutputType>::func ); in run_buffered_levels()
410 …( InputType i ) -> OutputType { return harness_graph_executor<InputType, OutputType>::func(i); } ); in run_unlimited_concurrency()
411 …nlimited_concurrency<InputType,OutputType>( &harness_graph_executor<InputType, OutputType>::func ); in run_unlimited_concurrency()
H A Dtest_multifunction_node.cpp221 …put_ports_type &p ) { harness_graph_multifunction_executor<InputType, OutputTuple>::func(i,p); } ); in run_buffered_levels()
222 …s<InputType,OutputTuple>( c, &harness_graph_multifunction_executor<InputType, OutputTuple>::func ); in run_buffered_levels()
398 …put_ports_type &p ) { harness_graph_multifunction_executor<InputType, OutputTuple>::func(i,p); } ); in run_unlimited_concurrency()
399 …ency<InputType,OutputTuple>( &harness_graph_multifunction_executor<InputType, OutputTuple>::func ); in run_unlimited_concurrency()
H A Dtest_eh_algorithms.cpp801 #define RunWithSimpleBody(func, body) \ argument
802 func<utils::ForwardIterator<size_t>, body>(); \
803 func<utils::ForwardIterator<size_t>, body##WithFeeder>()
805 #define RunWithTemplatedBody(func, body) \ argument
806 func<utils::ForwardIterator<size_t>, body<utils::ForwardIterator<size_t> > >(); \
807 func<utils::ForwardIterator<size_t>, body##WithFeeder<utils::ForwardIterator<size_t> > >()
H A Dtest_task.cpp819 auto func = [&count] { in __anon509d20bd2502() variable
824 tbb::detail::d0::raii_guard<decltype(func)> guard1(func);
825 tbb::detail::d0::raii_guard<decltype(func)> guard2(std::move(guard1));
H A Dtest_continue_node.cpp186 …) -> OutputType { return harness_graph_executor<tbb::flow::continue_msg, OutputType>::func(i); } ); in run_continue_nodes()
187 … continue_nodes<OutputType>( &harness_graph_executor<tbb::flow::continue_msg, OutputType>::func ); in run_continue_nodes()
H A Dtest_limiter_node.cpp616 tbb::flow::function_node<TestLargeStruct> func( graph, tbb::flow::serial, variable
619 tbb::flow::make_edge( input_node, func );
H A Dtest_concurrent_vector.cpp258 template<typename FuncType> void operator() ( FuncType func ) const { func(); } in operator ()()
/oneTBB/test/conformance/
H A Dconformance_collaborative_call_once.cpp74 auto func = [&flag] { flag++; }; in __anon8e61f74e0202() variable
79 oneapi::tbb::collaborative_call_once(once_flag_concurrent, func); in __anon8e61f74e0302()
/oneTBB/examples/graph/cholesky/
H A Dcholesky.cpp175 func(tile, n, b); in operator ()()
183 func(A0, n, b); in operator ()()
223 virtual void func(void *ptr, int n, int b) = 0;
269 virtual void func(void *ptr, int n, int b) { in func() function in algorithm_crout
292 virtual void func(void *ptr, int n, int /* b */) { in func() function in algorithm_dpotrf
469 virtual void func(void *ptr, int n, int b) { in func() function in algorithm_join
545 virtual void func(void *ptr, int n, int b) { in func() function in algorithm_depend
/oneTBB/src/tbbmalloc/
H A Dlarge_objects.cpp449 CacheBinFunctor<Props> func( this, extMemPool, bitMask, idx ); in ExecuteOperation() local
450 aggregator.execute( op, func, longLifeTime ); in ExecuteOperation()
452 if ( LargeMemoryBlock *toRelease = func.getToRelease()) { in ExecuteOperation()
456 if ( func.isCleanupNeeded() ) { in ExecuteOperation()
457 extMemPool->loc.doCleanup( func.getCurrTime(), /*doThreshDecr=*/false); in ExecuteOperation()
/oneTBB/examples/test_all/fibonacci/
H A Dfibonacci.cpp438 value Measure(const char *name, MeasureFunc func, int n) { in Measure() argument
444 result = func(number); in Measure()

12