python多进程处理数组

python多进程处理数组,第1张

多进程计算数组的平方
注意多进程为了多个进程共享数据,存储数据一定要用manager.list而不能用python自己的list

from multiprocessing import  Process, Manager

# 进程处理函数
def thread_func(sub_array, results, start):
    for index, num in enumerate(sub_array):
        results[start+index] = num**2

# 多进程计算数组的平方
if __name__ == '__main__':
    num_thread = 20
    array = list(range(100))

    with Manager() as manager:
        process_list = []
        results = manager.list(range(len(array)))

        for thr in range(num_thread):
            start, end = len(array) // num_thread * thr, len(array) // num_thread * (thr + 1)
            if thr == num_thread - 1:
                end = len(array)

            sub_array = array[start: end]
            p = Process(target=thread_func, args=(sub_array, results, start))
            p.start()
            process_list.append(p)
        for i in process_list:
            p.join()

        print('finish')
        print(results)

欢迎分享,转载请注明来源:内存溢出

原文地址:https://54852.com/langs/787173.html

(0)
打赏 微信扫一扫微信扫一扫 支付宝扫一扫支付宝扫一扫
上一篇 2022-05-05
下一篇2022-05-05

发表评论

登录后才能评论

评论列表(0条)

    保存