CMS 3D CMS Logo

List of all members | Public Member Functions | Public Attributes
edm::Worker::TaskQueueAdaptor Struct Reference

#include <Worker.h>

Public Member Functions

 operator bool ()
 
template<class F >
void push (F &&iF)
 
template<class F >
void pushAndWait (F &&iF)
 
 TaskQueueAdaptor ()=default
 
 TaskQueueAdaptor (SerialTaskQueueChain *iChain)
 
 TaskQueueAdaptor (LimitedTaskQueue *iLimited)
 

Public Attributes

LimitedTaskQueuelimited_ = 0
 
SerialTaskQueueChainserial_ = 0
 

Detailed Description

Definition at line 87 of file Worker.h.

Constructor & Destructor Documentation

edm::Worker::TaskQueueAdaptor::TaskQueueAdaptor ( )
default
edm::Worker::TaskQueueAdaptor::TaskQueueAdaptor ( SerialTaskQueueChain iChain)
inline

Definition at line 92 of file Worker.h.

92 : serial_(iChain) {}
SerialTaskQueueChain * serial_
Definition: Worker.h:88
edm::Worker::TaskQueueAdaptor::TaskQueueAdaptor ( LimitedTaskQueue iLimited)
inline

Definition at line 93 of file Worker.h.

93 : limited_(iLimited) {}
LimitedTaskQueue * limited_
Definition: Worker.h:89

Member Function Documentation

edm::Worker::TaskQueueAdaptor::operator bool ( )
inline

Definition at line 95 of file Worker.h.

References or.

95 { return serial_ != nullptr or limited_ != nullptr; }
SerialTaskQueueChain * serial_
Definition: Worker.h:88
LimitedTaskQueue * limited_
Definition: Worker.h:89
The Signals That Services Can Subscribe To This is based on ActivityRegistry and is current per Services can connect to the signals distributed by the ActivityRegistry in order to monitor the activity of the application Each possible callback has some defined which we here list in angle e< void, edm::EventID const &, edm::Timestamp const & > We also list in braces which AR_WATCH_USING_METHOD_ is used for those or
Definition: Activities.doc:12
template<class F >
void edm::Worker::TaskQueueAdaptor::push ( F &&  iF)
inline

Definition at line 98 of file Worker.h.

References edm::LimitedTaskQueue::push(), and edm::SerialTaskQueueChain::push().

98  {
99  if (serial_) {
100  serial_->push(iF);
101  } else {
102  limited_->push(iF);
103  }
104  }
void push(T &&iAction)
asynchronously pushes functor iAction into queue
void push(T &&iAction)
asynchronously pushes functor iAction into queue
SerialTaskQueueChain * serial_
Definition: Worker.h:88
LimitedTaskQueue * limited_
Definition: Worker.h:89
template<class F >
void edm::Worker::TaskQueueAdaptor::pushAndWait ( F &&  iF)
inline

Definition at line 106 of file Worker.h.

References EnergyCorrector::c, edm::LimitedTaskQueue::pushAndWait(), edm::SerialTaskQueueChain::pushAndWait(), and TrackValidation_cff::task.

106  {
107  if (serial_) {
108  serial_->pushAndWait(iF);
109  } else {
110  limited_->pushAndWait(iF);
111  }
112  }
void pushAndWait(T &&iAction)
synchronously pushes functor iAction into queue
SerialTaskQueueChain * serial_
Definition: Worker.h:88
LimitedTaskQueue * limited_
Definition: Worker.h:89
void pushAndWait(T &&iAction)
synchronously pushes functor iAction into queue

Member Data Documentation

LimitedTaskQueue* edm::Worker::TaskQueueAdaptor::limited_ = 0

Definition at line 89 of file Worker.h.

SerialTaskQueueChain* edm::Worker::TaskQueueAdaptor::serial_ = 0

Definition at line 88 of file Worker.h.