greenplumn CJobQueue 代码
文件路径：/src/backend/gporca/libgpopt/include/gpopt/search/CJobQueue.h
/---------------------------------------------------------------------------
/ Greenplum Database
/ Copyright (C) 2011 EMC Corp.
/
/ @filename:
/ CJobQueue.h
/
/ @doc:
/ Class controlling unique execution of an operation that is
/ potentially assigned to many jobs.
/---------------------------------------------------------------------------
#ifndef GPOPT_CJobQueue_H
#define GPOPT_CJobQueue_H
#include "gpos/base.h"
#include "gpos/common/CList.h"
#include "gpopt/search/CJob.h"
namespace gpopt
{
using namespace gpos;
/---------------------------------------------------------------------------
/ @class:
/ CJobQueue
/
/ @doc:
/ Forces unique execution of an operation assigned to many jobs.
/
/---------------------------------------------------------------------------
class CJobQueue
{
private:
/ main job
CJob *m_pj{nullptr};
/ flag indicating if main job has completed
BOOL m_fCompleted{false};
/ list of jobs waiting for main job to complete
CList<CJob> m_listjQueued;
public:
/ enum indicating job queueing result
enum EJobQueueResult
{
EjqrMain = 0,
EjqrQueued,
EjqrCompleted
};
/ ctor
CJobQueue()
{
m_listjQueued.Init(GPOS_OFFSET(CJob, m_linkQueue));
}
/ dtor
~CJobQueue()
{
GPOS_ASSERT_IMP(
nullptr != ITask::Self() && !ITask::Self()->HasPendingExceptions(),
m_listjQueued.IsEmpty());
}
/ reset job queue
void
Reset()
{
GPOS_ASSERT(m_listjQueued.IsEmpty());
m_pj = nullptr;
m_fCompleted = false;
}
/ add job as a waiter;
EJobQueueResult EjqrAdd(CJob *pj);
/ notify waiting jobs of job completion
void NotifyCompleted(CSchedulerContext *psc);
#ifdef GPOS_DEBUG
/ print queue - not thread-safe
IOstream &OsPrintQueuedJobs(IOstream &);
#endif / GPOS_DEBUG
}; / class CJobQueue
} / namespace gpopt
#endif / !GPOPT_CJobQueue_H
/ EOF
相关信息
相关文章
greenplumn CGroupExpression 源码
greenplumn CJobGroupExploration 源码