用Python编写进程调度算法代码

在Python中，我们可以使用内置的`multiprocessing`模块来实现简单的进程调度。一个常见的例子是使用`Pool`类创建一个工作池，然后通过`apply_async()`函数将任务提交给这个池并获取结果。这里是一个基础的线程池调度示例：

import multiprocessing

def worker(num):
    """代表一个需要调度的任务"""
    print(f"Worker {num} is running...")

if __name__ == "__main__":
    # 创建一个包含4个进程的工作池
    pool = multiprocessing.Pool(processes=4)

    # 使用列表存储待处理的任务
    tasks = [i for i in range(10)]

    # 提交任务到工作池，并获取一个Future对象
    results = [pool.apply_async(worker, (i,)) for i in tasks]

    # 等待所有任务完成
    for future in results:
        future.get()  # 获取结果或等待任务结束

    # 关闭工作池
    pool.close()
    pool.join()

在这个例子中，`worker`函数会被分配到工作池中的不同进程中执行。每个任务都是异步的，不会阻塞主进程。