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