OpenDX/src/dxvk/dxvk_queue.h

#pragma once

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

#include "dxvk_cmdlist.h"
#include "dxvk_sync.h"

namespace dxvk {
  
  class DxvkDevice;
  
  /**
   * \brief Submission queue
   * 
   * 
   */
  class DxvkSubmissionQueue {
    
  public:
    
    DxvkSubmissionQueue(DxvkDevice* device);
    ~DxvkSubmissionQueue();
    
    void submit(
      const Rc<DxvkFence>&        fence,
      const Rc<DxvkCommandList>&  cmdList);
    
  private:
    
    struct Entry {
      Rc<DxvkFence>       fence;
      Rc<DxvkCommandList> cmdList;
    };
    
    DxvkDevice*             m_device;
    
    std::atomic<bool>       m_stopped = { false };
    
    std::mutex              m_mutex;
    std::condition_variable m_condOnAdd;
    std::condition_variable m_condOnTake;
    std::queue<Entry>       m_entries;
    std::thread             m_thread;
    
    void threadFunc();
    
  };
  
}