[Hzi可乐][技术分享]一个大型任务处理轮子（重置）

uni_kevin

大家好我是花子家的可乐，今天在敲project的时候翻出了以前造的一个小轮子，用于把比较大的任务列表切片分到不同帧处理，比如说一次要放很多方块，或者创建很多实体，绑定很多文字面板什么的，貌似还挺有用，于是贴出来分享给大家~
创建一个TaskManager.py文件放到类似utils之类的文件夹下：

1. 
   
2. # coding=utf-8
   
3. import mod.server.extraServerApi as serverApi
   
4. 
   
5. 
   
6. class TaskManager:
   
7.     def __init__(self, speed=1):
   
8.         """
   
9. 
   
10.         :type speed: int
    
11.         """
    
12.         self.__speed = speed
    
13.         self.__taskList = list()
    
14.         self.__commandComp = serverApi.GetEngineCompFactory().CreateCommand(serverApi.GetLevelId())
    
15.         self.__isCloseWhenDone = False
    
16.         self.__callLater = serverApi.GetEngineCompFactory().CreateGame(serverApi.GetLevelId()).AddRepeatedTimer(1 / 20.0, self.__TickEvent)
    
17. 
    
18.     def __TickEvent(self):
    
19.         if len(self.__taskList) < self.__speed:
    
20.             for task in self.__taskList:
    
21.                 task.Execute()
    
22.             del self.__taskList[:]
    
23.             if self.__isCloseWhenDone:
    
24.                 serverApi.GetEngineCompFactory().CreateGame(serverApi.GetLevelId()).CancelTimer(self.__callLater)
    
25.                 del self
    
26.         else:
    
27.             for task in self.__taskList[0:self.__speed]:
    
28.                 task.Execute()
    
29.             del self.__taskList[0:self.__speed]
    
30. 
    
31.     def SetSpeed(self, speed, sync=False):
    
32.         """
    
33. 
    
34.         :param sync: bool
    
35.         :type speed: int
    
36.         """
    
37.         if sync:
    
38.             self.__speed = speed
    
39.         else:
    
40.             self.AppendFunction(self.SetSpeed, speed, True)
    
41. 
    
42.     def AppendCommand(self, command, playerId=None, showOutput=False):
    
43.         self.__taskList.append(TaskCommand(command, playerId, showOutput, self.__commandComp))
    
44. 
    
45.     def AppendFunction(self, func, *args, **kwargs):
    
46.         self.__taskList.append(TaskFunction(func, args, kwargs))
    
47. 
    
48.     def CloseWhenDone(self):
    
49.         self.__isCloseWhenDone = True
    
50. 
    
51. 
    
52. class TaskFunction:
    
53.     def __init__(self, function, args=None, kwargs=None):
    
54.         self.function = function
    
55.         self.args = args if args is not None else []
    
56.         self.b = kwargs if kwargs is not None else {}
    
57. 
    
58.     def Execute(self):
    
59.         self.function(*self.args, **self.b)
    
60. 
    
61. 
    
62. class TaskCommand:
    
63.     def __init__(self, command, playerId, showOutput, comp):
    
64.         self.command = command
    
65.         self.playerId = playerId
    
66.         self.showOutput = showOutput
    
67.         self.comp = comp
    
68. 
    
69.     def Execute(self):
    
70.         self.comp.SetCommand(self.command, self.playerId, self.showOutput)

复制代码

使用方法比较简单，首先创建一个实例，把速度（每tick处理多少个任务）（1s 20个tick）作为参数传进去，像这样：

1. taskManager = TaskManager(speed=1)
   

复制代码

对外接口有

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

复制代码

比方说，这样写种一棵树：

效果看起来是这样的：


还不错吧（应该？）
第一次写分享贴，我是萌新，技术一般般的，没法和圈里的大佬们比，如果有写的不对的地方还请多多包涵和指正qwq

鹅鹅鹅论坛的编辑好坑，上一个写错了还没法编辑麻烦管理员帮我删一下吧orz

sevenstars

实际上就是个取舍问题

sevenstars

把玩家卡死，可以保证最快处理完任务。
分批量处理任务，玩家等待时间较长
而且如果调的时间短了一样卡，无非是0fps和个位数fps的区别
对于一些大型任务，最好的办法还是让玩家选择是否低效率处理，或者直接通知玩家这个任务大约要卡多久，然后再卡死会好一点。