多处理一个队列并返回一个列表

Question

所以我正在尝试处理一个由两个邮政编码组成的队列。排队的功能是计算两个邮政编码之间的行车距离和直线距离。我希望函数同时返回两个值(行驶距离和直线距离(，并能够将这些值附加到列表中，以便以后使用。我对多处理还相当陌生，所以我不确定从这里开始该怎么办。我最初不确定是否可以通过池/队列传递两个参数，所以我决定尝试将两个邮政编码放入一个集合中，以便通过函数传递，尝试将其用作一个参数，然后分别提取必要的项。如果你需要我提供更多信息，请告诉我。

doc_num = []
origin_zip = []
origin_add = []
origin_city = []
destin_zip = []
destin_add = []
destin_city = []

#for i in range(14, len(data)-1):
for i in range(14, 16):   
doc_num.append(data['AutoTable+Fit.13'][i])
origin_add.append(data['AutoTable+Fit'][i])
origin_city.append(data['AutoTable+Fit.1'][i])
origin_zip.append(data['AutoTable+Fit.2'][i])
destin_add.append(data['AutoTable+Fit.8'][i])
destin_city.append(data['AutoTable+Fit.6'][i])
destin_zip.append(data['AutoTable+Fit.7'][i])
distances = []
def calculate_distances(q):
try:    
zip_sets = q.get()
drive = (gmaps.distance_matrix(zip_sets[1][0], zip_sets[1][1]))['rows'][0]['elements'][0]['distance']['value'] * 0.000621371
#print(f"Driving distance:", drive_dist)
LAT1 = gmaps.geocode(zip_sets[1][0])[0]['geometry']['location']['lat']
LONG1 = gmaps.geocode(zip_sets[1][0])[0]['geometry']['location']['lng']
LAT2 = gmaps.geocode(zip_sets[1][1])[0]['geometry']['location']['lat']
LONG2 = gmaps.geocode(zip_sets[1][1])[0]['geometry']['location']['lng']
distance = math.acos(math.cos(math.radians(90-(LAT1))) *math.cos(math.radians(90-(LAT2))) + math.sin(math.radians(90-(LAT1)))
* math.sin(math.radians(90-(LAT2))) * math.cos(math.radians((LONG1)-(LONG2)))) * 3958.756
except:
drive = -1
distance = -1
return (drive, distance)
q = Queue()
for x in range(len(origin_zip)):
q.put((origin_zip[x], destin_zip[x]))
pool = Pool(5)
pool.map(calculate_distances, (q,))
pool.close()
pool.join()

Answer 1

queue.Queue()不应用于将参数传递给worker的pool。相反，您应该直接向pool.map():传递一个可迭代的(例如，参数集的列表(

# Create a list of pairs as input to pool.map() (Not needed, see below)
pairs = [pair for pair in zip(origin_list, destin_list)]
distances = pool.map(calculate_distances, pairs)
pool.close()
pool.join()

然而，在这种情况下，pairs列表的创建是不必要的，因为zip操作的输出无论如何都是可迭代的，并且可以直接使用。此外，如果您正在运行Python 3.3或更高版本(我真诚地希望您这样做(，您应该考虑使用上下文管理器(with ...(，而不是pool.close()和pool.join()调用，从而获得以下代码：

with Pool(5) as pool:
distances = pool.map(calculate_distances, zip(origin_list, destin_list))

即没有明确的close()或join()以及没有邮政编码的中间列表。