blob: a83e48d0b6d9cbe982acfbec62250125480a04da (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
|
#include "KingSystem/ActorSystem/actBaseProcDeleter.h"
#include "KingSystem/ActorSystem/actActorParamMgr.h"
#include "KingSystem/ActorSystem/actBaseProc.h"
#include "KingSystem/Utils/SafeDelete.h"
#include "KingSystem/Utils/Thread/ManagedTask.h"
#include "KingSystem/Utils/Thread/TaskMgr.h"
#include "KingSystem/Utils/Thread/TaskQueue.h"
namespace ksys::act {
BaseProcDeleter::BaseProcDeleter() = default;
bool BaseProcDeleter::doPreDelete(void* proc) {
BaseProc::PreDeleteArg arg;
static_cast<BaseProc*>(proc)->doPreDelete(arg);
return true;
}
bool BaseProcDeleter::doUnloadParam(void* actor_param) {
ActorParamMgr::instance()->unloadParam(static_cast<ActorParam*>(actor_param));
return true;
}
BaseProcDeleter::~BaseProcDeleter() {
if (mTaskMgr) {
mTaskMgr->finalize();
util::safeDelete(mTaskMgr);
}
}
void BaseProcDeleter::init(const InitArg& arg) {
auto* heap = arg.heap;
mTaskQueue = arg.task_queue;
mTaskMgr = new (heap) util::TaskMgr(heap);
mTaskMgr->init<util::ManagedTask>(arg.task_queue_size, heap);
}
bool BaseProcDeleter::requestPreDelete(BaseProc* proc) {
util::TaskRequest request{false};
request.mSynchronous = false;
request.mQueue = mTaskQueue;
request.mDelegate = &mPreDeleteDelegate;
request.mUserData = proc;
request.mLaneId = u8(TaskLane::PreDelete);
request.mName = "PreDelete";
util::TaskMgrRequest req;
req.request = &request;
return mTaskMgr->trySubmitRequest(req);
}
void BaseProcDeleter::requestUnloadActorParam(ActorParam* param) {
util::TaskRequest request{false};
request.mSynchronous = false;
request.mQueue = mTaskQueue;
request.mDelegate = &mUnloadActorParamDelegate;
request.mUserData = param;
request.mLaneId = u8(TaskLane::UnloadActorParam);
request.mName = "UnloadActorParam";
util::TaskMgrRequest req;
req.request = &request;
mTaskMgr->submitRequest(req);
}
void BaseProcDeleter::unblockTasks() {
mTaskQueue->unblockTasks(u8(TaskLane::PreDelete));
mTaskQueue->unblockTasks(u8(TaskLane::UnloadActorParam));
}
} // namespace ksys::act
|
