SharedResourcesAcquirer.h

Go to the documentation of this file.

#ifndef FWCore_Framework_SharedResourcesAcquirer_h
#define FWCore_Framework_SharedResourcesAcquirer_h
// -*- C++ -*-
//
// Package:     FWCore/Framework
// Class  :     SharedResourcesAcquirer
//
//
// Original Author:  Chris Jones
//         Created:  Sun, 06 Oct 2013 19:43:26 GMT
//
 
// system include files
#include "FWCore/Concurrency/interface/SerialTaskQueueChain.h"
#include "FWCore/Utilities/interface/thread_safety_macros.h"
 
// user include files
 
// forward declarations
class testSharedResourcesRegistry;
 
namespace edm {
  class SerialTaskQueueChain;
  class SerialTaskQueue;
 
  class SharedResourcesAcquirer {
  public:
    friend class ::testSharedResourcesRegistry;
 
    SharedResourcesAcquirer() = default;
    explicit SharedResourcesAcquirer(std::vector<std::shared_ptr<SerialTaskQueue>> iQueues)
        : m_queues(std::move(iQueues)) {}
 
    SharedResourcesAcquirer(SharedResourcesAcquirer&&) = default;
    SharedResourcesAcquirer(const SharedResourcesAcquirer&) = delete;
    SharedResourcesAcquirer& operator=(const SharedResourcesAcquirer&) = delete;
 
    SharedResourcesAcquirer& operator=(SharedResourcesAcquirer&&) = default;
    ~SharedResourcesAcquirer() = default;
 
    // ---------- member functions ---------------------------
 
    size_t numberOfResources() const { return m_queues.numberOfQueues(); }
 
    SerialTaskQueueChain& serialQueueChain() const { return m_queues; }
 
  private:
    // ---------- member data --------------------------------
    //The class is thread safe even for non const functions
    CMS_THREAD_SAFE mutable SerialTaskQueueChain m_queues;
  };
}  // namespace edm
 
#endif