edm::WaitingTaskWithArenaHolder Class Reference

#include <WaitingTaskWithArenaHolder.h>

Public Member Functions
void	doneWaiting (std::exception_ptr iExcept)
WaitingTaskHolder	makeWaitingTaskHolderAndRelease ()
WaitingTaskWithArenaHolder &	operator= (const WaitingTaskWithArenaHolder &iRHS)
WaitingTaskWithArenaHolder &	operator= (WaitingTaskWithArenaHolder &&iRHS)
	WaitingTaskWithArenaHolder ()
	WaitingTaskWithArenaHolder (WaitingTask *iTask)
	WaitingTaskWithArenaHolder (WaitingTaskWithArenaHolder const &iHolder)
	WaitingTaskWithArenaHolder (WaitingTaskWithArenaHolder &&iOther)
	~WaitingTaskWithArenaHolder ()

Private Attributes
std::shared_ptr< tbb::task_arena >	m_arena
WaitingTask *	m_task

Detailed Description

Description: This holds a WaitingTask and can be passed to something the WaitingTask is waiting for. That allows that something to call doneWaiting to let the WaitingTask know it can run. The use of the arena allows one to call doneWaiting from a thread external to the arena where the task should run. The external thread might be a non-TBB thread.

Definition at line 32 of file WaitingTaskWithArenaHolder.h.

Constructor & Destructor Documentation

edm::WaitingTaskWithArenaHolder::WaitingTaskWithArenaHolder

(

)

Definition at line 15 of file WaitingTaskWithArenaHolder.cc.

                                                         : m_task(nullptr) {
  }

edm::WaitingTaskWithArenaHolder::WaitingTaskWithArenaHolder ( WaitingTask *  iTask )

explicit

Definition at line 21 of file WaitingTaskWithArenaHolder.cc.

References m_task.

                                                                           :
    m_task(iTask),
    m_arena(std::make_shared<tbb::task_arena>(tbb::task_arena::attach())) {

    m_task->increment_ref_count();
  }

edm::WaitingTaskWithArenaHolder::~WaitingTaskWithArenaHolder

(

)

Definition at line 28 of file WaitingTaskWithArenaHolder.cc.

References doneWaiting(), and m_task.

                                                          {
    if (m_task) {
      doneWaiting(std::exception_ptr{});
    }
  }

edm::WaitingTaskWithArenaHolder::WaitingTaskWithArenaHolder

(

WaitingTaskWithArenaHolder const &

iHolder

)

Definition at line 34 of file WaitingTaskWithArenaHolder.cc.

References m_task.

                                                                                                  :
    m_task(iHolder.m_task),
    m_arena(iHolder.m_arena) {

    m_task->increment_ref_count();
  }

edm::WaitingTaskWithArenaHolder::WaitingTaskWithArenaHolder

(

WaitingTaskWithArenaHolder &&

iOther

)

Definition at line 41 of file WaitingTaskWithArenaHolder.cc.

                                                                                            :
    m_task(iOther.m_task),
    m_arena(std::move(iOther.m_arena)) {

    iOther.m_task = nullptr;
  }

Member Function Documentation

void edm::WaitingTaskWithArenaHolder::doneWaiting

(

std::exception_ptr

iExcept

)

Definition at line 66 of file WaitingTaskWithArenaHolder.cc.

References edm::WaitingTask::dependentTaskFailed(), m_arena, and m_task.

Referenced by edm::Worker::runAcquireAfterAsyncPrefetch(), and ~WaitingTaskWithArenaHolder().

                                                                       {
    if (iExcept) {
      m_task->dependentTaskFailed(iExcept);
    }
    if (0 == m_task->decrement_ref_count()) {
      // The enqueue call will cause a worker thread to be created in
      // the arena if there is not one already.
      m_arena->enqueue( [m_task = m_task](){ tbb::task::spawn(*m_task); });
    }
    m_task = nullptr;
  }

WaitingTaskHolder edm::WaitingTaskWithArenaHolder::makeWaitingTaskHolderAndRelease

(

)

Definition at line 90 of file WaitingTaskWithArenaHolder.cc.

References m_task.

                                                                                {
    WaitingTaskHolder holder(m_task);
    m_task->decrement_ref_count();
    m_task = nullptr;
    return holder;
  }

WaitingTaskWithArenaHolder & edm::WaitingTaskWithArenaHolder::operator=

(

const WaitingTaskWithArenaHolder &

iRHS

)

Definition at line 48 of file WaitingTaskWithArenaHolder.cc.

References m_arena, m_task, std::swap(), and tmp.

                                                                                                          {
    WaitingTaskWithArenaHolder tmp(iRHS);
    std::swap(m_task, tmp.m_task);
    std::swap(m_arena, tmp.m_arena);
    return *this;
  }

WaitingTaskWithArenaHolder & edm::WaitingTaskWithArenaHolder::operator=

(

WaitingTaskWithArenaHolder &&

iRHS

)

Definition at line 55 of file WaitingTaskWithArenaHolder.cc.

References m_arena, m_task, eostools::move(), std::swap(), and tmp.

                                                                                                     {
    WaitingTaskWithArenaHolder tmp(std::move(iRHS));
    std::swap(m_task, tmp.m_task);
    std::swap(m_arena, tmp.m_arena);
    return *this;
  }

Member Data Documentation

std::shared_ptr<tbb::task_arena> edm::WaitingTaskWithArenaHolder::m_arena

private

Definition at line 75 of file WaitingTaskWithArenaHolder.h.

Referenced by doneWaiting(), and operator=().

WaitingTask* edm::WaitingTaskWithArenaHolder::m_task

private

Definition at line 74 of file WaitingTaskWithArenaHolder.h.

Referenced by doneWaiting(), makeWaitingTaskHolderAndRelease(), operator=(), WaitingTaskWithArenaHolder(), and ~WaitingTaskWithArenaHolder().