python - 如何在Python中并行化2个循环

Question

我需要在不同的线程中进行每次迭代(对于这两个循环中的每一个)。

var = 5
a = -7
b = 7
for i in range(var):
    for j in range(a, b):
        print(i, "   ", j)

我怎样才能做到？

更新:

var = 5
a = -7
b = 7
max = 0
for i in range(var):
    for j in range(a, b):
        print(i, "   ", j)
        if i+j>max:
            max=i+j
print(max)

Answer 1

您不能在不同的线程中运行这两个循环，因为第二个循环依赖于第一个循环中生成的数据。

一种方法是在不同的线程中运行第一个循环的每次迭代，如下所示:

from threading import Thread
var = 5
a = -7
b = 7

def inner_loop(i):
    for j in range(a, b):
        print(i, "   ", j)

for i in range(var):
    Thread(target=inner_loop, args=[i]).start()

另一种方式是生产者消费者模式。第一个循环生成 i 值并将其添加到队列中，第二个循环从队列读取值并生成 j 并打印 i 和 j 像这样:

from threading import Thread

var = 5
a = -7
b = 7

queue = []
finished = False

def inner_loop():
    while not finished or len(queue) > 0:
        if len(queue) == 0:
            continue
        i = queue.pop()
        for j in range(a, b):
            print(i, "   ", j)

def first_loop():
    for i in range(var):
        queue.append(i)
    finished = True

Thread(target=inner_loop).start()
Thread(target=first_loop).start()