我想用Python实现并行快速排序。我知道快速排序,你必须选择一个透视,分区,但是如何在Python中将它们派生为独立的任务?
下面是它的伪代码:
QS(A[1:n])
if n=1 then return A[1]
pivot <--any value from A (random)
L <- A[A[:] < pivot]
R <- A[A[:] > pivot]
A(L) <- spawn QS(L)
A(R) <- QS(R)
sync
return A(L) ++ A(R)发布于 2019-08-16 20:26:10
您可以做到这一点,但这不太可能加速您的代码。您可以使用ThreadPoolExecutor创建一个线程并从中获取结果。下面是一个简单的示例,其中包含一个对数组求和的函数:
from concurrent.futures import ThreadPoolExecutor
pool = ThreadPoolExecutor(max_workers=1)
def add(arr):
if len(arr)<2:
return sum(arr) #cheating a little
mid = len(arr)//2
f = pool.submit(add,arr[:mid])
y = add(arr[mid:])
return y+f.result()submit()将一个函数的名称作为第一个参数,然后再接受该函数的参数。因此,对于您的代码,它将类似于f = pool.submit(QS,L)。
请记住,虽然Python支持并发,但不支持使用线程的并行。看看他们的不同之处在here上。所以上面的代码实际上是在单线程中运行的。现在,您可以使用ProcessPoolExecutor实现进程并行,python对此支持得很好。但是,数据IO的开销可能会吞噬您从进程并行中获得的任何加速。
https://stackoverflow.com/questions/57513495
复制相似问题