Queue.h

Go to the documentation of this file.

// Copyright (c) 2018 the Talvos developers. All rights reserved.
//
// This file is distributed under a three-clause BSD license. For full license
// terms please see the LICENSE file distributed with this source code.


#ifndef TALVOS_QUEUE_H
#define TALVOS_QUEUE_H

#include <condition_variable>
#include <mutex>
#include <queue>
#include <set>
#include <thread>

namespace talvos
{

class Command;
class Device;

class Queue
{
public:
  Queue(Device &Dev);

  ~Queue();

  // Do not allow Queue objects to be copied.
  Queue(const Queue &) = delete;
  Queue &operator=(const Queue &) = delete;

  void submit(const std::vector<Command *> &NewCommands,
              volatile bool *Fence = nullptr);

  void waitIdle();

private:
  Device &Dev;

  std::queue<Command *> Commands;

  std::set<volatile bool *> Fences;

  // Background queue thread used to progress command execution.
  std::thread Thread;

  std::mutex Mutex;

  std::condition_variable StateChanged;

  volatile bool Running;

  void run();
};

} // namespace talvos

#endif