| /oneTBB/include/oneapi/tbb/ |
| H A D | concurrent_queue.h | 53 class concurrent_queue {
72 concurrent_queue() : concurrent_queue(allocator_type()) {} in concurrent_queue() function
88 concurrent_queue(a) in concurrent_queue() function
98 concurrent_queue(const concurrent_queue& src, const allocator_type& a) : in concurrent_queue() function
104 concurrent_queue(const concurrent_queue& src) : in concurrent_queue() function
111 concurrent_queue(concurrent_queue&& src) : in concurrent_queue() function
117 concurrent_queue(concurrent_queue&& src, const allocator_type& a) : in concurrent_queue() function
132 ~concurrent_queue() { in ~concurrent_queue()
139 concurrent_queue& operator=( const concurrent_queue& other ) {
149 concurrent_queue& operator=( concurrent_queue&& other ) {
[all …]
|
| /oneTBB/test/tbb/ |
| H A D | test_concurrent_queue.cpp | 61 TestPrimitiveTypes<tbb::concurrent_queue<char>, char>(MaxThread, (char)1); in TestQueueWorksWithPrimitiveTypes()
62 TestPrimitiveTypes<tbb::concurrent_queue<int>, int>(MaxThread, (int)-12); in TestQueueWorksWithPrimitiveTypes()
63 TestPrimitiveTypes<tbb::concurrent_queue<float>, float>(MaxThread, (float)-1.2f); in TestQueueWorksWithPrimitiveTypes()
64 TestPrimitiveTypes<tbb::concurrent_queue<double>, double>(MaxThread, (double)-4.3); in TestQueueWorksWithPrimitiveTypes()
108 TestVectorTypes<ClassWithSSE, tbb::concurrent_queue<ClassWithSSE> >(); in TestQueueWorksWithSSE()
113 TestVectorTypes<ClassWithAVX, tbb::concurrent_queue<ClassWithAVX> >(); in TestQueueWorksWithSSE()
172 using queue_type = tbb::concurrent_queue<int, allocator_type>;
198 CopyWithThrowElement<tbb::concurrent_queue<throw_element>>();
282 test_tracking_dtors_on_clear<oneapi::tbb::concurrent_queue<TrackableItem>>();
|
| H A D | test_concurrent_queue_whitebox.cpp | 90 tbb::concurrent_queue<int> q;
|
| H A D | test_hw_concurrency.cpp | 63 tbb::concurrent_queue<std::size_t> cq;
|
| H A D | test_tbb_header.cpp | 193 TestTypeDefinitionPresence( concurrent_queue<int> ); in DefinitionPresence()
|
| H A D | test_flow_graph_priorities.cpp | 218 class concurrent_queue { class
260 concurrent_queue<work_type> my_queue;
|
| /oneTBB/doc/main/tbb_userguide/ |
| H A D | Concurrent_Queue_Classes.rst | 7 Template class ``concurrent_queue<T,Alloc>`` implements a concurrent
45 extern concurrent_queue<T> MyQueue;
54 definition of "first" is uncertain. Use of ``concurrent_queue``
60 Template class ``concurrent_queue`` is unbounded and has no methods that
85 The value of concurrent_queue::size() is defined as the number of push
88 ``concurrent_queue`` is empty, and there are ``n`` pending pop
102 bounds or the blocking pop, consider using ``concurrent_queue`` instead.
|
| H A D | Iterating_Over_a_Concurrent_Queue_for_Debugging.rst | 7 The template classes ``concurrent_queue`` and
19 concurrent_queue<Foo> q;
21 typedef concurrent_queue<Foo>::const_iterator iter;
|
| /oneTBB/test/conformance/ |
| H A D | conformance_concurrent_queue.cpp | 57 using base_type = oneapi::tbb::concurrent_queue<T, test_allocator<T>>;
259 class ConcQWithSizeWrapper : public oneapi::tbb::concurrent_queue<T, A> {
268 : oneapi::tbb::concurrent_queue<T, A>(std::move(q), a) { } in ConcQWithSizeWrapper()
272 : oneapi::tbb::concurrent_queue<T, A>(begin, end, a) {} in ConcQWithSizeWrapper()
1534 test_member_types<oneapi::tbb::concurrent_queue>();
1574 TestDeductionGuides<oneapi::tbb::concurrent_queue>();
1581 TestQueueIteratorComparisons<oneapi::tbb::concurrent_queue<int>>();
1677 test_with_minimalistic_objects<oneapi::tbb::concurrent_queue>();
1714 test_queue_helper<tbb::concurrent_queue<std::vector<int>>>();
1825 tbb::concurrent_queue<std::vector<int>> dst(src.get_allocator()); in test_move_assignment_test_equal()
[all …]
|
| /oneTBB/doc/main/tbb_userguide/design_patterns/ |
| H A D | GUI_Thread.rst | 94 oneapi::tbb::concurrent_queue<Foo>ResultQueue;
188 The example uses a ``concurrent_queue`` for workers to communicate
193 versa. Using ``concurrent_queue`` provides a simple robust solution.
|
| H A D | Local_Serializer.rst | 54 ``concurrent_queue`` for the FIFO and ``atomic<int>`` to count the
202 oneapi::tbb::concurrent_queue<WorkItem*> queue;
231 Mutexes are avoided by using ``concurrent_queue<WorkItem*>`` and
|
| H A D | Non-Preemptive_Priorities.rst | 128 oneapi::tbb::concurrent_queue<WorkItem*> level[P_Low+1];
|
| /oneTBB/examples/test_all/fibonacci/ |
| H A D | fibonacci.cpp | 124 oneapi::tbb::concurrent_queue<Matrix2x2> Q; in SerialQueueFib()
268 typedef oneapi::tbb::concurrent_queue<Matrix2x2> queue_t;
|
| /oneTBB/examples/concurrent_priority_queue/shortpath/ |
| H A D | README.md | 8 …y needed, so we could use this same parallel algorithm with just a `concurrent_queue`. However, ke…
|