pythonのthreadingでスレッド同士で変数の受け渡し方法を教えてください。

Question

pythonのスレッド間で変数の受け渡し方法がわからず困っています。
やりたいことは、非同期で動くスレッド１で計算する数値ｘと、スレッド２で計算する数値ｙを別のスレッドで合算することなのですが、うまくできません。自分で下記のように書いてみたのですが、機能しませんでした。x_score関数とy_score関数で計算した数値を、z_scoreでどうやって取得できるのでしょうか？ネットで探してもぴったりの解説がなく、行き詰ってしまったので質問いたします。どなたか教えていただけると幸いです。よろしくお願いいたします。

import threading
import time


def z_score(x,y):
    zx=0
    zy=0
    if x>0 and y==0:
      zx=x
    if x==0 and y<0:
      zy=y
    z=zx+zy
    print(z)
    time.sleep(1)

th_3 = threading.Thread(target=z_score)
th_3.start()

def x_score():
    x=1
    while True:
      x=x+1
      z_score(x,0)
      time.sleep(1)

th_1 = threading.Thread(target=x_score)
th_1.start()

def y_score():
    y=-1
    while True:
      y=y-2
      z_score(0,y)
      time.sleep(2)

th_2 = threading.Thread(target=y_score)
th_2.start()

Comments

[退会済みユーザー]

th_1, th_2の終了条件はどうするんですか？

[ros_tana]

ご質問ありがとうございます。th_1, th_2はそれぞれずっと動き続ける感じです。

Answer 1

変数をmultiprocessing.Valueに変更して、
それ(ら)をスレッド間で共有するようにすれば良いです。

from multiprocessing import Value

x = Value('i')
print(x.value)
with x.get_lock():
    x.value += 1
print(x.value)

Comments

[ros_tana]

ご回答ありがとうございます！返信が遅くなって申し訳ありません。threadingではなく、multiprocessingにすれば変数を共有できるわけですね。自分でコードを書けるか挑戦してみます。希望が見えてきました。ありがとうございます！

[YouheiSakurai]

いえいえ、threadingのままでもValueを使えばできますよ。ご参考までに。

Answer 2

th_3 = threading.Thread(target=z_score)
th_3.start()
の2行を消せばとりあえず動きますが…