greenplumn CJobQueue 源码
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 源码
0
赞
热门推荐
-
2、 - 优质文章
-
3、 gate.io
-
6、 golang
-
8、 openharmony