マルチプロセッシングが機能しない

Question

大規模な距離行列を計算するための並列ソフトウェアを実装する必要があります。

これは私が書いたコードです：

subset = #[list of proper objects] 
nthreads = 10 

def compute_distance_corcoeff(geneset, offset, q): 
    for i in range(offset, len(geneset), nthreads): 
     g1 = geneset[i] 
     dvect = [np.corrcoef(g1.expr, g2.expr)[0,1] for g2 in geneset] 
     q.put((i,dvect)) 

queue = Queue() 
processes = [] 
for off in range(nthreads): 
    processes.append(Process(target=compute_distance_corcoeff, args=(subset, off, queue))) 

for p in processes: 
    p.start() 
for p in processes: 
    p.join() 

私は、キューからの部分的な結果を収集します。

残念ながら、何も起こっていないようです。それはjoin()で立ち往生しているようです。

私はここで何が欠けていますか？

Answer 1

multiprocessing programming guidelinesで説明したように、まずQueueを空にしてからProcessに参加する必要があります。

あなたのロジックは、Queueのメッセージが消費されるのを待っているため、プロセスが終了できないため、デッドロック状態になります。