G4RunToolEventQueue.h

Go to the documentation of this file.

/*
  Copyright (C) 2002-2026 CERN for the benefit of the ATLAS collaboration
*/
 
#ifndef G4RUNMANAGEMENT_G4RUNTOOLEVENTQUEUE_H
#define G4RUNMANAGEMENT_G4RUNTOOLEVENTQUEUE_H
 
#include "G4RunManagement/AtlasG4SyncEventUserInfo.h"
 
#include <condition_variable>
#include <cstddef>
#include <memory>
#include <mutex>
#include <queue>
#include <vector>

class G4RunToolEventQueue
{
 public:
  using UPEvent = std::unique_ptr<AtlasG4SyncEventUserInfo>;
 
  std::size_t Size() const;
  void PushEvent(UPEvent event);
  UPEvent GetEvent();

  void Close() noexcept;

  void CompleteOutstandingEvents() noexcept;
 
 private:
  using WeakSyncInterface =
    std::weak_ptr<G4EventSynchronizationInterface>;
 
  std::queue<UPEvent> m_events;
  std::vector<WeakSyncInterface> m_outstandingEvents;
  bool m_closed{false};
  mutable std::mutex m_mutex;
  std::condition_variable m_cv;
};
 
#endif