Home
last modified time | relevance | path

Searched refs:self (Results 1 – 15 of 15) sorted by relevance

/oneTBB/python/tbb/
H A Dpool.py218 def join(self): argument
224 return self
227 self.join()
231 self.join()
287 result = self._func(*self._args, **self._kwds)
348 raise self._data[0](self._data[1]).with_traceback(self._data[2])
377 self._collector.notify_ready(self)
395 self._collector.notify_ready(self)
552 self._to_notify._set_value(iter(self))
611 got_first = (len(self._results) == self._remaining)
[all …]
H A D__init__.py87 for i in range(self._processes - len(self._pool)):
89 args=(self._inqueue, self._outqueue,
91 self._initargs, self._maxtasksperchild)
100 self.close()
105 self.close()
129 for i in range(self._processes - len(self._pool)):
131 args=(self._inqueue, self._outqueue,
143 self.close()
148 self.close()
210 return self
[all …]
H A Dapi.i125 void enqueue( PyObject *c ) { $self->enqueue(PyCaller(c)); } in enqueue()
126 void execute( PyObject *c ) { $self->execute(PyCaller(c)); } in execute()
137 void run( PyObject *c ) { $self->run(PyCaller(c)); } in run()
138 void run( PyObject *c, task_arena *a ) { $self->run(ArenaPyCaller(a, c)); } in run()
/oneTBB/test/tbbmalloc/
H A Dtest_malloc_shutdown_hang.cpp65 void processSpawn(const char* self) { in processSpawn() argument
66 _spawnl(_P_WAIT, self, self, "1", nullptr); in processSpawn()
71 void processSpawn(const char* self) { in processSpawn() argument
76 execl(self, self, "1", nullptr); in processSpawn()
114 const char* self = argv[0]; in main() local
116 processSpawn(self); in main()
/oneTBB/examples/common/gui/xcode/tbbExample/
H A DOpenGLView.m68 CGPoint point = [[touches anyObject] locationInView:self];
73 [self setNeedsDisplay];
77 if( cocoa_update ) [self setNeedsDisplay];
97 glWindowPos2i(0, (int)self.visibleRect.size.height);
98 glPixelZoom( (float)self.visibleRect.size.width /(float)g_sizex,
99 -(float)self.visibleRect.size.height/(float)g_sizey);
105 if( cocoa_update ) [self setNeedsDisplay:YES];
118 NSRect rect = self.visibleRect;
120 [self setNeedsDisplay:YES];
135 NSRect rect = self.visibleRect;
[all …]
/oneTBB/include/oneapi/tbb/
H A Dpartitioner.h175 TreeNodeType* self = static_cast<TreeNodeType*>(n); in fold_tree() local
176 self->join(ed.context); in fold_tree()
177 self->m_allocator.delete_object(self, ed); in fold_tree()
282 if ( self().is_divisible() ) { in execute()
289 self().work_balance(start, range, ed); in execute()
327 self().my_divisor = do_split(src, split_obj); in proportional_mode()
336 return self().my_divisor > my_partition::factor; in is_divisible()
365 using proportional_mode<Partition>::self;
373 if (self().my_divisor) { in spawn_task()
388 using Mode::self;
[all …]
H A Dmemory_pool.h212 memory_pool<Alloc> &self = *reinterpret_cast<memory_pool<Alloc>*>(pool_id); in allocate_request() local
219 ptr = self.my_alloc.allocate( bytes/unit_size ); in allocate_request()
235 memory_pool<Alloc> &self = *reinterpret_cast<memory_pool<Alloc>*>(pool_id); in deallocate_request() local
238 …self.my_alloc.deallocate( static_cast<typename Alloc::value_type*>(raw_ptr), raw_bytes/unit_size ); in deallocate_request()
254 fixed_pool &self = *reinterpret_cast<fixed_pool*>(pool_id); in allocate_request() local
255 __TBBMALLOC_ASSERT(0 != self.my_size, "The buffer must not be used twice."); in allocate_request()
256 bytes = self.my_size; in allocate_request()
257 self.my_size = 0; // remember that buffer has been used in allocate_request()
258 return self.my_buffer; in allocate_request()
H A Dflow_graph.h2914 async_node* self() { return this; } in __TBB_requires()
2943 (body, &my_gateway), a_priority ), my_gateway(self()) { in __TBB_requires()
2972 …YM async_node( const async_node &other ) : base_type(other), sender<Output>(), my_gateway(self()) { in __TBB_requires()
/oneTBB/include/oneapi/tbb/detail/
H A D_segment_table.h175 segment_type new_segment = self()->create_segment(table, seg_index, index); in enable_segment()
183 self()->deallocate_segment(new_segment, seg_index); in enable_segment()
192 segment_type segment_to_delete = self()->nullify_segment(get_table(), seg_index); in delete_segment()
200 self()->destroy_segment(segment_to_delete, seg_index); in delete_segment()
283 table = self()->allocate_long_table(my_embedded_table, start_index); in extend_table_if_necessary()
325 derived_type* self() { in self() function
331 my_instance.self()->copy_segment(index, from, to); in operator()
338 my_instance.self()->move_segment(index, from, to); in operator()
/oneTBB/test/tbb/
H A Dtest_parallel_scan.cpp158 Accumulator* self; member in Accumulator
165 self = this; in Accumulator()
169 self = nullptr; in ~Accumulator()
180 self = this; in Accumulator()
189 CHECK_MESSAGE(self==this, "this Accumulator corrupted or prematurely destroyed"); in operator ()()
199 CHECK(left_body.self == &left_body); in reverse_join()
207 CHECK(self == this); in assign()
208 CHECK_MESSAGE(other.self==&other, "other Accumulator corrupted or prematurely destroyed"); in assign()
H A Dtest_partitioner.h119 T right = self().compute_right_part(r, p); in RangeBase()
120 size_t right_part = self().round(right); in RangeBase()
137 DerivedRange& self() { return static_cast<DerivedRange&>(*this); } in self() function
/oneTBB/python/rml/
H A Dipc_server.cpp505 ipc_worker* self = static_cast<ipc_worker*>(arg); in thread_routine() local
506 AVOID_64K_ALIASING( self->my_index ); in thread_routine()
507 self->run(); in thread_routine()
647 ipc_waker* self = static_cast<ipc_waker*>(arg); in thread_routine() local
648 AVOID_64K_ALIASING( self->my_index ); in thread_routine()
649 self->run(); in thread_routine()
746 ipc_stopper* self = static_cast<ipc_stopper*>(arg); in thread_routine() local
747 AVOID_64K_ALIASING( self->my_index ); in thread_routine()
748 self->run(); in thread_routine()
/oneTBB/src/tbb/
H A Dprivate_server.cpp219 private_worker* self = static_cast<private_worker*>(arg); in thread_routine() local
220 AVOID_64K_ALIASING( self->my_index ); in thread_routine()
221 self->run(); in thread_routine()
/oneTBB/test/common/
H A Dconcurrent_unordered_common.h201 T& self( T& obj ) { in self() function
277 c6 = self(c6); in TypeTester()
286 c7 = std::move(self(c7)); in TypeTester()
/oneTBB/doc/main/tbb_userguide/
H A Dcancel_a_graph.rst69 task::self().group()->cancel_group_execution();