Python多处理速度问题

Question

我有一个嵌套的 for 表单循环

while x<lat2[0]:
    while y>lat3[1]:
        if (is_inside_nepal([x,y])):
            print("inside")
        else:
            print("not")
        y = y - (1/150.0)
    y = lat2[1]
    x = x + (1/150.0)
#here lat2[0] represents a large number

现在这通常需要 50 秒来执行。 我已将此循环更改为多处理代码。

def v1find_coordinates(q):
  while not(q.empty()):

    x1 = q.get()
    x2 = x1 + incfactor
    while x1<x2:
        def func(x1): 
            while y>lat3[1]:
                if (is_inside([x1,y])):
                    print x1,y,"inside"
                else:
                    print x1,y,"not inside"
                y = y - (1/150.0)

        func(x1)
        y = lat2[1]
        x1 = x1 + (1/150.0)

incfactor = 0.7
xvalues = drange(x,lat2[0],incfactor)
#this drange function is to get list with increment factor as decimal
cores = mp.cpu_count()
q = Queue()
for i in xvalues:
    q.put(i)
for i in range(0,cores):
    p = Process(target = v1find_coordinates,args=(q,) )
    p.start()
    p.Daemon = True
    processes.append(p) 
for i in processes:
    print ("now joining")
    i.join()   

这个多处理代码也需要大约 50 秒的执行时间。这意味着两者之间没有时间差。

我也尝试过使用池。我还管理了块大小。我已经用谷歌搜索并搜索了其他stackoverflow。但是找不到满意的答案。

我能找到的唯一答案是花时间进行流程管理以使两者结果相同。 如果这是原因，那么我怎样才能让多处理工作获得更快的结果？

用 C 语言从 Python 实现会带来更快的结果吗？

我并不期待会有剧烈的结果，但根据常识，我们可以看出，在 4 核上运行应该比在 1 核上运行要快得多。但我得到了类似的结果。任何形式的帮助将不胜感激。

Answer 1

您似乎正在使用线程队列（来自队列导入队列）。这不能按预期工作，因为 Process 使用 fork() 并将整个队列克隆到每个工作进程中

用途：

from multiprocessing import Queue