greenplumn CAutoTaskProxy 代码
文件路径：/src/backend/gporca/libgpos/include/gpos/task/CAutoTaskProxy.h
/---------------------------------------------------------------------------
/ Greenplum Database
/ Copyright (C) 2010 Greenplum, Inc.
/
/ @filename:
/ CAutoTaskProxy.h
/
/ @doc:
/ Interface class for task management and execution.
/---------------------------------------------------------------------------
#ifndef GPOS_CAutoTaskProxy_H
#define GPOS_CAutoTaskProxy_H
#include "gpos/base.h"
#include "gpos/common/CList.h"
#include "gpos/task/CTask.h"
#include "gpos/task/CTaskContext.h"
#include "gpos/task/CWorkerPoolManager.h"
namespace gpos
{
/---------------------------------------------------------------------------
/ @class:
/ CAutoTaskProxy
/
/ @doc:
/ Auto task proxy (ATP) to handle task creation, execution and cleanup
/ ATP operations are not thread-safe; only one worker can use each ATP
/ object.
/
/---------------------------------------------------------------------------
class CAutoTaskProxy : CStackObject
{
private:
/ memory pool
CMemoryPool *m_mp;
/ worker pool
CWorkerPoolManager *m_pwpm;
/ task list
CList<CTask> m_list;
/ propagate error of sub-task or not
BOOL m_propagate_error;
/ find finished task
GPOS_RESULT
FindFinished(CTask **task);
/ propagate the error from sub-task to current task
static void PropagateError(CTask *sub_task);
/ check error from sub-task
void CheckError(CTask *sub_task) const;
public:
CAutoTaskProxy(const CAutoTaskProxy &) = delete;
/ ctor
CAutoTaskProxy(CMemoryPool *mp, CWorkerPoolManager *m_pwpm,
BOOL propagate_error = true);
/ dtor
~CAutoTaskProxy();
/ task count
ULONG
TaskCount()
{
return m_list.Size();
}
/ disable/enable error propagation
void
SetPropagateError(BOOL propagate_error)
{
m_propagate_error = propagate_error;
}
/ create new task
CTask *Create(void *(*pfunc)(void *), void *argv, BOOL *cancel = nullptr);
/ schedule task for execution
void Schedule(CTask *task);
/ execute task in thread owning ATP (synchronous execution)
void Execute(CTask *task) const;
/ cancel task
void Cancel(CTask *task);
/ unregister and release task
void Destroy(CTask *task);
/ unregister and release all tasks
void DestroyAll();
}; / class CAutoTaskProxy
} / namespace gpos
#endif / !GPOS_CAutoTaskProxy_H_
/ EOF
相关信息
相关文章
greenplumn CAutoSuspendAbort 源码
greenplumn CTaskLocalStorage 源码
greenplumn CTaskLocalStorageObject 源码