ThreadSafeFunctor.h

Go to the documentation of this file.

#ifndef CommonTools_Utils_ThreadSafeFunctor_H
#define CommonTools_Utils_ThreadSafeFunctor_H

#include "FWCore/Utilities/interface/thread_safety_macros.h"

#include <mutex>
#include <utility>

// This class is a simple wrapper around some functor class to use its operator() in a thread-safe way.

template <class Functor>
class ThreadSafeFunctor {
public:
  template <typename... Params>
  ThreadSafeFunctor(Params&&... params) : functor_{std::forward<Params>(params)...} {}

  ThreadSafeFunctor(ThreadSafeFunctor&& other) noexcept : functor_(std::move(other.functor_)) {}

  template <typename... Params>
  typename std::invoke_result_t<Functor, Params...> operator()(Params&&... params) const {
    std::lock_guard<std::mutex> guard(mutex_);
    return functor_(std::forward<Params>(params)...);
  }

private:
  const Functor functor_;
  CMS_THREAD_SAFE mutable std::mutex mutex_;
};

#endif