SerialTaskQueue.cpp

Go to the documentation of this file.

/*
 * SerialTaskQueue.cpp
 *
 * @date   2012-10-21
 * @author Marco Clemencic
 */

#include "GaudiKernel/SerialTaskQueue.h"

namespace Gaudi {

  SerialTaskQueue::SerialTaskQueue(): m_count(0) {
  }

  SerialTaskQueue::~SerialTaskQueue() {
    wait();
  }

  SerialTaskQueue::WorkItem::~WorkItem() {
  }

  void SerialTaskQueue::add(WorkItem *item) {
    m_queue.push(new SerialWorkItem(item, this));
    if (++m_count == 1)
      i_startNextItem();
  }

  void SerialTaskQueue::noteCompletion() {
    if (--m_count!=0)
      i_startNextItem();
  }

  void SerialTaskQueue::wait() const {
    // wait until the queue is empty and all the tasks are completed
    while((!m_queue.empty()) || m_count) {}
  }

  void SerialTaskQueue::i_startNextItem() {
    SerialWorkItem *item = 0;
    m_queue.try_pop(item);
    tbb::task::enqueue(*new(tbb::task::allocate_root()) SerialWorkItemRunner(item));
  }

} /* namespace Gaudi */