PriorityTaskThread类 参考

类 PriorityTaskThread 继承关系图:

PriorityTaskThread 的协作图:

Public 成员函数
	__init__ (self, str name="PriorityTaskThread")
None	start (self)
None	run (self)
str	add_task (self, Task task)
str	insert_high_priority_task (self, Task task)
Optional[Dict[str, Any]]	get_task_result (self, str task_id, bool block=False, Optional[float] timeout=None)
bool	is_task_done (self, str task_id)
List[Task]	clear_tasks (self)
None	stop (self)
None	stopAfterAllComplete (self)

Public 属性
	task_queue = queue.PriorityQueue()
dict	task_results = {}
bool	running = False
	lock = threading.Lock()

成员函数说明

add_task()

str add_task	(		self,
		Task	task )

添加任务，返回任务ID（用于后续查询结果）

这是这个函数的调用关系图:

clear_tasks()

List[Task] clear_tasks

(

self

)

清空未执行的任务，返回被清空的任务列表

这是这个函数的调用关系图:

get_task_result()

Optional[Dict[str, Any]] get_task_result	(		self,
		str	task_id,
		bool	block = False,
		Optional[float]	timeout = None )

获取任务结果

Args:
    task_id: 任务唯一ID
    block: 是否阻塞等待结果（未完成则等待）
    timeout: 阻塞等待的超时时间（秒），仅block=True时有效

Returns:
    任务结果字典（包含status、result/error等），超时返回None

insert_high_priority_task()

str insert_high_priority_task	(		self,
		Task	task )

插入最高优先级任务（强制优先级为1），返回任务ID

函数调用图:

is_task_done()

bool is_task_done	(		self,
		str	task_id )

检查任务是否已完成

run()

None run

(

self

)

执行任务并保存结果

stop()

None stop

(

self

)

停止线程并清理资源

函数调用图:

这是这个函数的调用关系图:

stopAfterAllComplete()

None stopAfterAllComplete

(

self

)

完成所有任务后听hi

函数调用图:

---

该类的文档由以下文件生成:

• swarm/distsim/MoreThreadTaskExecutor.py