[Hzi可乐][技术分享]一个大型任务处理轮子（重置） - 网易我的世界论坛

# coding=utf-8
import mod.server.extraServerApi as serverApi
class TaskManager:
def __init__(self, speed=1):
"""
:type speed: int
"""
self.__speed = speed
self.__taskList = list()
self.__commandComp = serverApi.GetEngineCompFactory().CreateCommand(serverApi.GetLevelId())
self.__isCloseWhenDone = False
self.__callLater = serverApi.GetEngineCompFactory().CreateGame(serverApi.GetLevelId()).AddRepeatedTimer(1 / 20.0, self.__TickEvent)
def __TickEvent(self):
if len(self.__taskList) < self.__speed:
for task in self.__taskList:
task.Execute()
del self.__taskList[:]
if self.__isCloseWhenDone:
serverApi.GetEngineCompFactory().CreateGame(serverApi.GetLevelId()).CancelTimer(self.__callLater)
del self
else:
for task in self.__taskList[0:self.__speed]:
task.Execute()
del self.__taskList[0:self.__speed]
def SetSpeed(self, speed, sync=False):
"""
:param sync: bool
:type speed: int
"""
if sync:
self.__speed = speed
else:
self.AppendFunction(self.SetSpeed, speed, True)
def AppendCommand(self, command, playerId=None, showOutput=False):
self.__taskList.append(TaskCommand(command, playerId, showOutput, self.__commandComp))
def AppendFunction(self, func, *args, **kwargs):
self.__taskList.append(TaskFunction(func, args, kwargs))
def CloseWhenDone(self):
self.__isCloseWhenDone = True
class TaskFunction:
def __init__(self, function, args=None, kwargs=None):
self.function = function
self.args = args if args is not None else []
self.b = kwargs if kwargs is not None else {}
def Execute(self):
self.function(*self.args, **self.b)
class TaskCommand:
def __init__(self, command, playerId, showOutput, comp):
self.command = command
self.playerId = playerId
self.showOutput = showOutput
self.comp = comp
def Execute(self):
self.comp.SetCommand(self.command, self.playerId, self.showOutput)

复制代码

taskManager = TaskManager(speed=1)

复制代码

taskManager.AppendFunction(...) # 添加一个任务，类似官方timer组件传参即可
taskManager.AppendCommand(...) # 添加一个指令任务
taskManager.SetSpeed(3, sync=False) # 中途修改速度, 第二个参数是否不等待任务执行到此马上更改
taskManager.CloseWhenDone() # 设置执行完全部任务后释放资源, 销毁后就不能再添加任务了

复制代码