GFifo.h

Go to the documentation of this file.

#ifndef GALOIS_WORKLIST_GFIFO_H
#define GALOIS_WORKLIST_GFIFO_H

#include "Galois/Runtime/ll/PaddedLock.h"
#include "Galois/gdeque.h"
#include "WLCompileCheck.h"

namespace Galois {
namespace WorkList {

template<typename T = int, bool Concurrent = true>
struct GFIFO : private boost::noncopyable, private Runtime::LL::PaddedLock<Concurrent>  {
  template<bool _concurrent>
  struct rethread { typedef GFIFO<T, _concurrent> type; };

  template<typename _T>
  struct retype { typedef GFIFO<_T, Concurrent> type; };

private:
  gdeque<T> wl;

  using Runtime::LL::PaddedLock<Concurrent>::lock;
  using Runtime::LL::PaddedLock<Concurrent>::try_lock;
  using Runtime::LL::PaddedLock<Concurrent>::unlock;

public:
  GFIFO() {} //required for apparent bug in clang
  typedef T value_type;

  void push(const value_type& val) {
    lock();
    wl.push_back(val);
    unlock();
  }

  template<typename Iter>
  void push(Iter b, Iter e) {
    lock();
    while (b != e)
      wl.push_back(*b++);
    unlock();
  }

  template<typename RangeTy>
  void push_initial(const RangeTy& range) {
    if (Runtime::LL::getTID() == 0)
      push(range.begin(), range.end());
  }

  Galois::optional<value_type> pop() {
    Galois::optional<value_type> retval;
    lock();
    if (!wl.empty()) {
      retval = wl.front();
      wl.pop_front();
    }
    unlock();
    return retval;
  }
};
GALOIS_WLCOMPILECHECK(GFIFO)

} // end namespace WorkList
} // end namespace Galois

#endif

---