TaskBase.h

Go to the documentation of this file.

#ifndef FWCore_Concurrency_TaskBase_h
#define FWCore_Concurrency_TaskBase_h
// -*- C++ -*-
//
// Package:     Concurrency
// Class  :     TaskBase
//
//
// Original Author:  Chris Jones
//         Created:  Tue Jan 5 13:46:31 CST 2020
// $Id$
//
 
// system include files
#include <atomic>
#include <exception>
#include <memory>
 
// user include files
 
// forward declarations
 
namespace edm {
  class TaskBase {
  public:
    friend class TaskSentry;
 
    TaskBase() : m_refCount{0} {}
    virtual ~TaskBase() = default;
 
    virtual void execute() = 0;
 
    void increment_ref_count() { ++m_refCount; }
    unsigned int decrement_ref_count() { return --m_refCount; }
 
  private:
    virtual void recycle() { delete this; }
 
    std::atomic<unsigned int> m_refCount{0};
  };
 
  class TaskSentry {
  public:
    TaskSentry(TaskBase* iTask) : m_task{iTask} {}
    ~TaskSentry() { m_task->recycle(); }
    TaskSentry() = delete;
    TaskSentry(TaskSentry const&) = delete;
    TaskSentry(TaskSentry&&) = delete;
    TaskSentry operator=(TaskSentry const&) = delete;
    TaskSentry operator=(TaskSentry&&) = delete;
 
  private:
    TaskBase* m_task;
  };
}  // namespace edm
 
#endif