以下是一个模拟并行处理作业列表的示例代码:
import time
from multiprocessing import Process
def process_job(job):
# 模拟处理作业的逻辑
print(f'Starting job {job}...')
time.sleep(2) # 模拟处理作业的耗时
print(f'Finished job {job}.')
def parallel_processing(job_list):
processes = []
for job in job_list:
p = Process(target=process_job, args=(job,))
p.start()
processes.append(p)
# 等待所有子进程完成
for p in processes:
p.join()
if __name__ == '__main__':
job_list = ['Job 1', 'Job 2', 'Job 3', 'Job 4']
parallel_processing(job_list)
在上面的代码中,process_job
函数模拟了处理作业的逻辑,通过time.sleep
函数来模拟作业的耗时。parallel_processing
函数接收一个作业列表作为输入,并创建一个子进程来处理每个作业。最后,通过join
方法等待所有子进程完成。
可以根据实际需求修改job_list
的内容,增加或减少作业的数量。此代码示例是使用Python的multiprocessing
模块来实现并行处理,可以在多核CPU上实现真正的并行处理。