请问python这段代码怎么改造成多线程增加运行效率

url = "http://127.0.0.1:18201/idy2"

while True:
task = TaskReward.select(
TaskReward.task_id,
TaskReward.employee_id
).join(
Task, JOIN.INNER, on=(Task.id == TaskReward.task_id)
).where((TaskReward.state == 1) & ((Task.type == 1) | (Task.type == 2)))

task = list(task.dicts())
api = TRestAPI()
for line in task:
    task_id = line.get('task_id')
    employee_id = line.get('employee_id')
    try:
        taskreward = TaskReward.getone((TaskReward.task_id == task_id) & (TaskReward.employee_id == employee_id) & (TaskReward.state != 1))
        if taskreward != None:
            pass
        retval = api.post2(url, line)
        v = json.loads(retval)
        logger.info("%s, %s " % (line, v))
        if v.get('success'):
            result = v.get('success')
            if result == True:
                task_reward = TaskReward.getone((TaskReward.task_id == task_id) & (TaskReward.employee_id == employee_id))
                query = TaskReward.update(state=3, update_time=TDateUtil.now(), operator="system_auto").where(((TaskReward.state == 2) | (TaskReward.state == 1)) & (TaskReward.id == task_reward.id)).execute()
                if query == 0:
                    pass

                Employee.update(balance=Employee.balance + task_reward.reward).where(Employee.id == employee_id).execute()

                employee = Employee.getone(Employee.id == employee_id)
                task = Task.getone(Task.id == task_reward.task_id)
                TLBAdminProviderProfit().update_my_profit(employee.provider_id, employee.cooperator_id, task.price, task.commission)
                reason = "任务审核通过到账%s元" % (task.commission / 100)
                message = Messages()
                message.employee_id = employee_id
                message.msg_type = 4
                message.text = {"task_id": task.id, "state": 3, "msg": "审核已通过", "reason": reason}
                message.create_time = TDateUtil.now()
                message.save()
                message_str = Messages.getone(Messages.id == message.id)
                print(message_str.text, type(message_str.text))
                TMQTT().send_message(message_str.text, employee_id)

            if result == False:
                task_reward = TaskReward.getone((TaskReward.task_id == task_id) & (TaskReward.employee_id == employee_id))
                TaskReward.update(state=4, update_time=TDateUtil.now(), operator="system_auto", check_result="自动审核失败").where(((TaskReward.state == 2) | (TaskReward.state == 1)) & (TaskReward.id == task_reward.id)).execute()

        task_reward = TaskReward.getone((TaskReward.task_id == task_id) & (TaskReward.employee_id == employee_id))
        TaskReward.update(state=4, update_time=TDateUtil.now(), operator="system_auto",
                          check_result="自动审核失败").where(((TaskReward.state == 2) | (TaskReward.state == 1)) & (TaskReward.id == task_reward.id)).execute()

    except Exception as e:
        task_reward = TaskReward.getone((TaskReward.task_id == task_id) & (TaskReward.employee_id == employee_id))
        TaskReward.update(state=4, update_time=TDateUtil.now(), operator="system_auto", check_result="自动审核失败").where(((TaskReward.state == 2) | (TaskReward.state == 1)) & (TaskReward.id == task_reward.id)).execute()

time.sleep(1)

https://blog.csdn.net/qq_39338671/article/details/87457812