| The Gaudi Framework v27r1

- Main Page
- Related Pages
- Modules
- Namespaces
- Classes
- Files

- File List
- File Members

SerialTaskQueue.cpp
Go to the documentation of this file.
1 /*
2 * SerialTaskQueue.cpp
3 *
4 * @date 2012-10-21
5 * @author Marco Clemencic
6 */
7
8 #include "GaudiKernel/SerialTaskQueue.h"
9
10 namespace Gaudi {
11
12 SerialTaskQueue::SerialTaskQueue(): m_count(0) {
13 }
14
15 SerialTaskQueue::~SerialTaskQueue() {
16 wait();
17 }
18
19 SerialTaskQueue::WorkItem::~WorkItem() {
20 }
21
22 void SerialTaskQueue::add(WorkItem *item) {
23 m_queue.push(new SerialWorkItem(item, this));
24 if (++m_count == 1)
25 i_startNextItem();
26 }
27
28 void SerialTaskQueue::noteCompletion() {
29 if (--m_count!=0)
30 i_startNextItem();
31 }
32
33 void SerialTaskQueue::wait() const {
34 // wait until the queue is empty and all the tasks are completed
35 while((!m_queue.empty()) || m_count) {}
36 }
37
38 void SerialTaskQueue::i_startNextItem() {
39 SerialWorkItem *item = 0;
40 m_queue.try_pop(item);
41 tbb::task::enqueue(*new(tbb::task::allocate_root()) SerialWorkItemRunner(item));
42 }
43
44 } /* namespace Gaudi */
Gaudi::SerialTaskQueue::WorkItem::~WorkItem
virtual ~WorkItem()
Definition: SerialTaskQueue.cpp:19
Gaudi::SerialTaskQueue::i_startNextItem
void i_startNextItem()
Definition: SerialTaskQueue.cpp:38
Gaudi::SerialTaskQueue::WorkItem
Base class for the task to be executed by the serial queue.
Definition: SerialTaskQueue.h:36
Gaudi::SerialTaskQueue::m_queue
tbb::concurrent_queue< SerialWorkItem * > m_queue
Queue of the tasks to be executed.
Definition: SerialTaskQueue.h:101
Gaudi::SerialTaskQueue::SerialWorkItem
Wrapper for the WorkItem class for internal concurrency bookkeeping.
Definition: SerialTaskQueue.h:64
Gaudi::SerialTaskQueue::wait
void wait() const
Block until all the currently enqueued tasks are completed.
Definition: SerialTaskQueue.cpp:33
Gaudi::SerialTaskQueue::SerialTaskQueue
SerialTaskQueue()
Default constructor.
Definition: SerialTaskQueue.cpp:12
Gaudi::SerialTaskQueue::~SerialTaskQueue
virtual ~SerialTaskQueue()
Block until all the enqueued tasks are completed.
Definition: SerialTaskQueue.cpp:15
Gaudi::SerialTaskQueue::add
void add(WorkItem *item)
Enqueue a WorkItem for execution.
Definition: SerialTaskQueue.cpp:22
ana.item
tuple item
print s1,s2
Definition: ana.py:146
Gaudi::SerialTaskQueue::SerialWorkItemRunner
Helper class to wrap a SerialWorkItem in a tbb::task.
Definition: SerialTaskQueue.h:81
Gaudi::SerialTaskQueue::noteCompletion
void noteCompletion()
Method used by the tasks to trigger the execution of the next task in the queue.
Definition: SerialTaskQueue.cpp:28
Gaudi
Helper functions to set/get the application return code.
Definition: __init__.py:1
SerialTaskQueue.h
Gaudi::SerialTaskQueue::m_count
std::atomic< int > m_count
Counter of the currently running tasks.
Definition: SerialTaskQueue.h:99