任务禁用

添加或删除禁用任务名称

add_ban_task_name(task_name: str) -> None

remove_ban_task_name(task_name: str) -> None

• 警告:

已经进入调度器的任务将不会被处理，只有在任务状态为queued才会被取消

• 参数说明:

task_name: 函数名字

• 使用示例:

import time


def line_task(input_info):
    while True:
        time.sleep(1)
        print(input_info)


input_info = "test"

if __name__ == "__main__":
    from task_scheduling.task_creation import task_creation
    from task_scheduling.manager import task_scheduler
    from task_scheduling.server_webui import start_task_status_ui
    from task_scheduling.variable import *

    start_task_status_ui()

    # 创建第一个任务
    task_id1 = task_creation(None, None, FUNCTION_TYPE_IO, True, "task1", line_task, priority_low, input_info)

    # 添加任务名称到黑名单
    task_scheduler.add_ban_task_name("task1")

    # 这个任务将被拦截
    task_id2 = task_creation(None, None, FUNCTION_TYPE_IO, True, "task1", line_task, priority_low, input_info)

    # 从黑名单移除
    task_scheduler.remove_ban_task_name("task1")

    # 这个任务可以正常创建
    task_id3 = task_creation(None, None, FUNCTION_TYPE_IO, True, "task1", line_task, priority_low, "1111")

取消队列中某类任务

cancel_the_queue_task_by_name(task_name: str) -> None

• 警告:

已经进入调度器的任务将不会被处理，只有在任务状态为queued才会被取消

• 参数说明:

task_name: 函数名字

• 使用示例:

import time


def line_task(input_info):
    while True:
        time.sleep(1)
        print(input_info)


input_info = "test"

if __name__ == "__main__":
    from task_scheduling.task_creation import task_creation
    from task_scheduling.manager import task_scheduler
    from task_scheduling.server_webui import start_task_status_ui
    from task_scheduling.variable import *

    start_task_status_ui()

    # 创建第一个任务
    task_id1 = task_creation(None, None, FUNCTION_TYPE_IO, True, "task1", line_task, priority_low, input_info)

    # 取消队列中的任务
    task_scheduler.cancel_the_queue_task_by_name("task1")