edm::LimitedTaskQueue Class Reference

#include <LimitedTaskQueue.h>

Public Member Functions
unsigned int	concurrencyLimit () const
	LimitedTaskQueue (unsigned int iLimit)
template<typename T >
void	push (const T &iAction)
	asynchronously pushes functor iAction into queue More...
template<typename T >
void	pushAndWait (const T &iAction)
	synchronously pushes functor iAction into queue More...

Private Member Functions
	LimitedTaskQueue (const LimitedTaskQueue &)=delete
const LimitedTaskQueue &	operator= (const LimitedTaskQueue &)=delete

Private Attributes
std::vector< SerialTaskQueue >	m_queues

Detailed Description

Definition at line 38 of file LimitedTaskQueue.h.

Constructor & Destructor Documentation

edm::LimitedTaskQueue::LimitedTaskQueue ( unsigned int  iLimit )

inline

Definition at line 41 of file LimitedTaskQueue.h.

References push(), and pushAndWait().

Referenced by concurrencyLimit().

                                          :
     m_queues{iLimit}
      {  }

edm::LimitedTaskQueue::LimitedTaskQueue ( const LimitedTaskQueue &  )

privatedelete

Member Function Documentation

unsigned int edm::LimitedTaskQueue::concurrencyLimit ( ) const

inline

Definition at line 69 of file LimitedTaskQueue.h.

References LimitedTaskQueue(), m_queues, and operator=().

{ return m_queues.size(); }

const LimitedTaskQueue& edm::LimitedTaskQueue::operator= ( const LimitedTaskQueue &  )

privatedelete

Referenced by concurrencyLimit().

template<typename T >

void LimitedTaskQueue::push

(

const T &

iAction

)

asynchronously pushes functor iAction into queue

The function will return immediately and iAction will either process concurrently with the calling thread or wait until the protected resource becomes available or until a CPU becomes available.

Parameters

[in]

iAction

Must be a functor that takes no arguments and return no values.

Definition at line 79 of file LimitedTaskQueue.h.

References m_queues, and lumiQueryAPI::q.

Referenced by LimitedTaskQueue(), and edm::Worker::TaskQueueAdaptor::push().

                                               {
     auto set_to_run = std::make_shared<std::atomic<bool>>(false);
     for(auto& q: m_queues) {
       q.push([set_to_run,iAction]() {
         bool expected = false;
         if(set_to_run->compare_exchange_strong(expected,true)) {
           iAction();
         }
       });
     }
   }

template<typename T >

void LimitedTaskQueue::pushAndWait

(

const T &

iAction

)

synchronously pushes functor iAction into queue

The function will wait until iAction has completed before returning. If another task is already running on the queue, the system is allowed to find another TBB task to execute while waiting for the iAction to finish. In that way the core is not idled while waiting.

Parameters

[in]

iAction

Must be a functor that takes no arguments and return no values.

Definition at line 92 of file LimitedTaskQueue.h.

References pyrootRender::destroy(), m_queues, and lumiQueryAPI::q.

Referenced by LimitedTaskQueue(), and edm::Worker::TaskQueueAdaptor::pushAndWait().

                                                      {
      tbb::empty_task* waitTask = new (tbb::task::allocate_root()) tbb::empty_task;
      waitTask->set_ref_count(2);
     auto set_to_run = std::make_shared<std::atomic<bool>>(false);
     for(auto& q: m_queues) {
       q.push([set_to_run,waitTask,iAction]() {
         bool expected = false;
         if(set_to_run->compare_exchange_strong(expected,true)) {
           try {
             iAction();
           }catch(...) {}
           waitTask->decrement_ref_count();
         }
       });
     }
     waitTask->wait_for_all();
     tbb::task::destroy(*waitTask);
   }

Member Data Documentation

std::vector<SerialTaskQueue> edm::LimitedTaskQueue::m_queues

private

Definition at line 75 of file LimitedTaskQueue.h.

Referenced by concurrencyLimit(), push(), and pushAndWait().