AthAsynchronousAlgorithm.h

Go to the documentation of this file.

 
/*
  Copyright (C) 2024 - 2025 CERN for the benefit of the ATLAS collaboration
*/
 
// AthAsynchronousAlgorithm.h
// Header file for class AthAsynchronousAlgorithm
// Author: Beojan Stanislaus
#ifndef ATHENABASECOMPS_ATHASYNCHRONOUSALGORITHM_H
#define ATHENABASECOMPS_ATHASYNCHRONOUSALGORITHM_H 1
 
// Framework includes
#include "AthenaBaseComps/AthCommonReentrantAlgorithm.h"
#include "CxxUtils/checker_macros.h"
#include "Gaudi/AsynchronousAlgorithm.h"
 
// Other includes
#include <boost/fiber/all.hpp>
 
class AthAsynchronousAlgorithm
    : public AthCommonReentrantAlgorithm<Gaudi::AsynchronousAlgorithm> {
  using AthCommonReentrantAlgorithm<
      Gaudi::AsynchronousAlgorithm>::AthCommonReentrantAlgorithm;
 
 public:
  StatusCode sysExecute(const EventContext& ctx) override;
 
  virtual StatusCode restoreAfterSuspend() const override;
 
 protected:
  // This is local to each fiber so it can't be accessed from multiple threads
  // at once
  mutable boost::fibers::fiber_specific_ptr<EventContext> m_currentCtx
      ATLAS_THREAD_SAFE{nullptr};
};
 
#endif  //> !ATHENABASECOMPS_ATHASYNCHRONOUSALGORITHM_H