multiprocessing の join　がうまく機能しない

以下のコードにて関数something()の因数nが10など小さい値のときは正常に出力されるのですが、nが100000など大きくなると正常に機能しなくなります。
「完了」という文字は出力されるため、関数sopmething()は明らかに終了しているのに、multiprocessing.join()の所で処理が止まったままになります。
重い処理を行うとjoin()は機能しなくなってしまうのでしょうか？

python
1from multiprocessing import Process, Queue
2
3def something(queue, n):
4
5    queue.put([i for i in range(n)])
6
7    print("完了")
8
9if __name__ == "__main__":
10
11    test = Queue()
12
13    p1 = Process(target = something, args = (test, 100000))
14    p1.start()
15    p1.join()
16
17    print(test.get())
18
19###出力
20#n=10のとき
21#完了
22#[0, 1, 2, 3, 4, 5, 6, 7, 8, 9]
23
24#n = 100000のとき
25#完了
26#

行動規範の内容に同意します

回答1件

ベストアンサー

パイプ (Pipe) とキュー (Queue)

警告上述したように、もし子プロセスがキューへ要素を追加するなら (かつ JoinableQueue.cancel_join_thread を使用しないなら) そのプロセスはバッファーされたすべての要素がパイプへフラッシュされるまで終了しません。

これは、そのプロセスを join しようとする場合、キューに追加されたすべての要素が消費されたことが確実でないかぎり、デッドロックを発生させる可能性があることを意味します。似たような現象で、子プロセスが非デーモンプロセスの場合、親プロセスは終了時に非デーモンのすべての子プロセスを join しようとしてハングアップする可能性があります。

との記載のケースに該当しているようです。
すなわちキューに要素が残っているのに.joinしているためデッドロックが発生しています。
よってたとえば以下のようにプロセス終了待ちのあとに.getにて要素を取り出せばよいです。
参考：python multiprocessing .join() deadlock depends on worker function

Python
1if __name__ == "__main__":
2
3    test = Queue()
4
5    p1 = Process(target = something, args = (test, 100000))
6    p1.start()
7    while p1.is_alive():
8        pass
9    print(test.get())
10    #p1.join()
11    #print(test.get())