python并行计算求和的方法是什么

39次阅读

共计 1039 个字符，预计需要花费 3 分钟才能阅读完成。

在 Python 中进行并行计算求和可以通过使用多进程或多线程来实现。以下是使用多进程和多线程的示例代码：

使用多进程：

import multiprocessing

def sum_worker(data_chunk, result_queue):
    result = sum(data_chunk)
    result_queue.put(result)

data = [1, 2, 3, 4, 5, 6, 7, 8, 9, 10]
chunk_size = len(data) // 4

result_queue = multiprocessing.Queue()
processes = []

for i in range(4):
    start = i * chunk_size
    end = start + chunk_size
    p = multiprocessing.Process(target=sum_worker, args=(data[start:end], result_queue))
    processes.append(p)
    p.start()

for p in processes:
    p.join()

total_sum = 0
while not result_queue.empty():
    total_sum += result_queue.get()

print(total_sum)

使用多线程：

import threading

def sum_worker(data_chunk, result_list):
    result = sum(data_chunk)
    result_list.append(result)

data = [1, 2, 3, 4, 5, 6, 7, 8, 9, 10]
chunk_size = len(data) // 4

result_list = []
threads = []

for i in range(4):
    start = i * chunk_size
    end = start + chunk_size
    t = threading.Thread(target=sum_worker, args=(data[start:end], result_list))
    threads.append(t)
    t.start()

for t in threads:
    t.join()

total_sum = sum(result_list)
print(total_sum)