queueモジュールを使いプロセス間でデータを受け渡す方法について

Question

実現したいこと

queueモジュールを使い2つのプロセス間でデータの受け渡しを行いたいです。
具体的には、
プロセス1では1秒間隔でキューにデータを貯めて、
プロセス2では2秒間隔でキューに溜まったデータを取り出したいです。

発生している問題

プリント文の出力結果からデータの受け渡しはできてそうなのですが、メインループのtime.sleep(6)後の"flg_get.value = 0"が反映されずプロセスを終了することができません。
根本的なやり方が間違っているのでしょうか？

該当のソースコード/試したこと

import time
from multiprocessing import Queue, Process, Value


def DataPut(q, flg_put):
    global data
    data = 1
    while flg_put.value:
        time.sleep(1)
        q.put(data)
        print("flg_put:%d, val:%d" %(flg_put.value, data))
        data += 1
    print("stop p1")


def DataGet(q, flg_get):
    global data_list
    while flg_get.value:

        time.sleep(2)

        data_list = []
        while not q.empty():
            data_list.append( q.get() )
        print("flg_get:%d, val:%s" %(flg_get.value, str(data_list)))

    print("stop p2")
    print(data_list)




q = Queue()
flg_put = Value('i', 1)
flg_get = Value('i', 1)


if __name__ == "__main__":

    p1 = Process( target = DataPut, args=(q, flg_put) )
    p1.start()
    p2 = Process( target = DataGet, args=(q, flg_get) )
    p2.start()    


    time.sleep(6)

    flg_get.value = 0  # Get Stop
    print("flg_get:%d" % flg_get.value)
    p2.join()
    flg_put.value = 0  # Put Stop
    print("flg_put:%d" % flg_put.value)
    p1.join()
    print("Stop p1 and p2" )

    print("########### END ###########")

補足情報

Windows10 64bit
python 3.8.2

Answer 1

flg_get, flg_put をそれぞれ Process の引数(args)で渡してみてください。

グローバル経由で参照すると、
別々に確保された Value オブジェクトになってしまい、
期待するようなデータの共有が出来ません。

処理内容は追ってませんが、以下は出力結果。

flg_get:1, val:[1, 2]
flg_get:1, val:[3]
flg_get:0, val:[4, 5]
stop p2
[4, 5]
flg_put:1, val:1
flg_put:1, val:2
flg_put:1, val:3
flg_put:1, val:4
flg_put:1, val:5
flg_put:1, val:6
flg_put:0, val:7
stop p1
flg_get:0
flg_put:0
Stop p1 and p2
########### END ###########

Comments

[Goga]

teamiklさん、ご回答ありがとうございます。flg_get, flg_put をそれぞれ Process の引数(args)に渡すこと、不要なグローバル変数の削除で所望の動作が確認できました。ありがとうございました。