Gaudi::Utils::PeriodicAction Class Reference

Helper to periodically run asynchronous tasks. More...

#include </builds/gaudi/Gaudi/GaudiUtils/include/Gaudi/Utils/PeriodicAction.h>

Collaboration diagram for Gaudi::Utils::PeriodicAction:

Public Types
using	clock = std::chrono::system_clock
using	time_point = clock::time_point
using	callback_t = std::function< void()>

Public Member Functions
	PeriodicAction (callback_t callback, std::chrono::milliseconds period_duration, bool autostart=true)
	PeriodicAction (PeriodicAction &&)=default
PeriodicAction &	operator= (PeriodicAction &&)=default
	~PeriodicAction ()
void	start ()
void	stop ()

Private Attributes
std::thread	m_thread
std::promise< void >	m_stop_thread
callback_t	m_callback
std::chrono::milliseconds	m_period_duration

Detailed Description

Helper to periodically run asynchronous tasks.

An instance of this starts a dedicated thread that periodically runs the user specified callback.

The thread starts as soon as the instance is created and it's automatically terminated (and joined) on destruction. It's also possible to defer the start (if requested at construction time) and anticipate the stop.

Definition at line 29 of file PeriodicAction.h.

Member Typedef Documentation

callback_t

using Gaudi::Utils::PeriodicAction::callback_t = std::function<void()>

Definition at line 33 of file PeriodicAction.h.

clock

using Gaudi::Utils::PeriodicAction::clock = std::chrono::system_clock

Definition at line 31 of file PeriodicAction.h.

time_point

using Gaudi::Utils::PeriodicAction::time_point = clock::time_point

Definition at line 32 of file PeriodicAction.h.

Constructor & Destructor Documentation

PeriodicAction() [1/2]

PeriodicAction::PeriodicAction	(	callback_t	callback,
		std::chrono::milliseconds	period_duration,
		bool	autostart = true
	)

Definition at line 16 of file PeriodicAction.cpp.

    : m_callback{ std::move( callback ) }, m_period_duration{ period_duration } {
  if ( autostart ) start();
}

PeriodicAction() [2/2]

Gaudi::Utils::PeriodicAction::PeriodicAction ( PeriodicAction &&  )

default

~PeriodicAction()

PeriodicAction::~PeriodicAction

(

)

Definition at line 21 of file PeriodicAction.cpp.

{ stop(); }

Member Function Documentation

operator=()

PeriodicAction& Gaudi::Utils::PeriodicAction::operator= ( PeriodicAction &&  )

default

start()

void PeriodicAction::start

(

)

Definition at line 23 of file PeriodicAction.cpp.

                           {
  if ( !m_thread.joinable() ) {
    // Note: we can move the callback because we are not going to use it
    // outside of the thread
    m_thread = std::thread{ [period_duration = m_period_duration, callback = std::move( m_callback ),
                             stop_signal = m_stop_thread.get_future()] {
      auto next_call = clock::now() + period_duration;
      while ( stop_signal.wait_until( next_call ) == std::future_status::timeout ) {
        callback();
        // ensure the next call is at a multiple
        // of m_period_duration after the last one
        const auto now = clock::now();
        while ( next_call < now ) next_call += period_duration;
      }
    } };
  }
}

stop()

void PeriodicAction::stop

(

)

Definition at line 41 of file PeriodicAction.cpp.

                          {
  if ( m_thread.joinable() ) {
    m_stop_thread.set_value();
    m_thread.join();
  }
}

Member Data Documentation

m_callback

callback_t Gaudi::Utils::PeriodicAction::m_callback

private

Definition at line 47 of file PeriodicAction.h.

m_period_duration

std::chrono::milliseconds Gaudi::Utils::PeriodicAction::m_period_duration

private

Definition at line 48 of file PeriodicAction.h.

m_stop_thread

std::promise<void> Gaudi::Utils::PeriodicAction::m_stop_thread

private

Definition at line 46 of file PeriodicAction.h.

m_thread

std::thread Gaudi::Utils::PeriodicAction::m_thread

private

Definition at line 45 of file PeriodicAction.h.

---

The documentation for this class was generated from the following files:

• GaudiUtils/include/Gaudi/Utils/PeriodicAction.h
• GaudiUtils/src/Lib/PeriodicAction.cpp