并发.futures._base模块中的任务优先级调度和结果获取方法

在concurrent.futures._base模块中，任务优先级调度是通过指定Executor中的submit()方法的priority参数来实现的。priority参数接受一个整数值，用于设置任务的优先级，数值越小表示优先级越高。

在concurrent.futures._base模块中，结果获取是通过Future对象的result()方法来实现的。result()方法会阻塞当前线程直到任务完成并返回结果值。

下面是一个使用示例，演示了如何使用任务优先级调度和获取任务结果的方法：

import concurrent.futures

# 定义一个简单的任务函数
def task(num):
    print(f"Processing task: {num}")
    return num ** 2

# 创建一个优先级调度的线程池
executor = concurrent.futures.ThreadPoolExecutor()

# 提交5个任务到线程池
futures = []
for i in range(5):
    priority = 5 - i  # 设置任务的优先级，优先级从5递减到1
    future = executor.submit(task, i, priority=priority)
    futures.append(future)

# 获取任务结果
results = []
for future in concurrent.futures.as_completed(futures):
    result = future.result()  # 阻塞当前线程，直到任务完成并返回结果
    results.append(result)
    print(f"Task {future} completed with result: {result}")
    
print("All tasks completed.")

运行上面的示例代码，会输出类似以下结果：

Processing task: 4
Processing task: 2
Processing task: 1
Processing task: 0
Processing task: 3
Task <Future at 0x7f3230> completed with result: 9
Task <Future at 0x7f3210> completed with result: 1
Task <Future at 0x7f3220> completed with result: 4
Task <Future at 0x7f3240> completed with result: 16
Task <Future at 0x7f3250> completed with result: 0
All tasks completed.

从输出结果可以看出，任务的优先级是通过priority参数指定的，优先级高的任务首先被调度执行。每个任务的计算结果是通过result()方法获取的，并且结果的顺序与任务的提交顺序一致。

需要注意的是，ThreadPoolExecutor是使用线程池来处理任务的。除了ThreadPoolExecutor之外，还有ProcessPoolExecutor可以使用多个进程来处理任务。两者的用法几乎相同，只需要将代码中的ThreadPoolExecutor替换为ProcessPoolExecutor即可。

总结起来，concurrent.futures._base模块提供了任务优先级调度和任务结果获取的方法，可以方便地控制任务的执行顺序和获取任务的结果。这些方法的使用可以提高任务执行效率，并且可以根据实际需求对任务进行优先级排序。