WorkQueue.h

Go to the documentation of this file.

#ifndef WorkQueue_HEADER
#define WorkQueue_HEADER

#ifdef HAVE_CONFIG_H
# include <config.h>
#endif

#include <deque>
#include <boost/array.hpp>
#include "MeshTypes.h"
#include "WorkItem.h"
#include <utilities/BucketPQ.h>

#if 0
#define dprintf(...) printf(__VA_ARGS__);
#else
#define dprintf(...)
#endif


template <size_t ambient>
class WorkQueue {
  typedef ::WorkItem<ambient> WorkItem;

  struct WorkItemQueue {
    boost::array<hudson::BucketDoublePQ<WorkItem*>, ambient+1> queues_;
    // boost::array<hudson::FrontStack<WorkItem*>, ambient+1> queues_;

    void push(WorkItem* w) {
      assert(w); // no nulls
      queues_[w->topological()].push(w->size(), w);
      // queues_[w->topological()].push(w);
    }

    WorkItem *pop() {
      for(size_t i = 0; i <= ambient; ++i) {
        if (!queues_[i].empty()) {
          WorkItem *w = queues_[i].top();
          queues_[i].pop();
          return w;
        }
      }
      return NULL;
    }
  };

  public:
  void push(WorkItem *w) {
    assert(w);
    assert(w->getReason() < WorkItem::NONE);
    dprintf("  pushing %s\n", w->toString().c_str());
    queues_[w->getReason()].push(w);
  }

  WorkItem *pop() {
    for(size_t r = 0; r < WorkItem::NONE; ++r) {
      WorkItem *item = queues_[r].pop();
      if (item) return item;
    }

    // Nothing:  All queues are empty.
    return NULL;
  }

  private:
  boost::array<WorkItemQueue, WorkItem::NONE> queues_;
};

#undef dprintf

#endif

---