greenplumn CAutoTaskProxy 源码
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 源码
0
赞
热门推荐
-
2、 - 优质文章
-
3、 gate.io
-
7、 golang
-
9、 openharmony
-
10、 Vue中input框自动聚焦