クラススレッド間でメッセージを送信する

Question

グローバル変数を使用せずに、このコードでthreadOneからthreadTwoに変数を（または変数を）送信する方法を知っている人はいますか？そうでない場合は、グローバル変数をどのように操作しますか？両方のクラスの前に定義し、実行関数でグローバル定義を使用するだけですか？

import threading 

print "Press Escape to Quit" 

class threadOne(threading.Thread): #I don't understand this or the next line 
    def run(self): 
     setup() 

    def setup(): 
     print 'hello world - this is threadOne' 


class threadTwo(threading.Thread): 
    def run(self): 
     print 'ran' 

threadOne().start() 
threadTwo().start() 

おかげ

Answer 1

あなたは、スレッドセーフな方法でスレッド間でメッセージを送信するためにqueuesを使用することができます。

def worker(): 
    while True: 
     item = q.get() 
     do_work(item) 
     q.task_done() 

q = Queue() 
for i in range(num_worker_threads): 
    t = Thread(target=worker) 
    t.daemon = True 
    t.start() 

for item in source(): 
    q.put(item) 

q.join()  # block until all tasks are done 

Answer 2

ここでは、Lockを使用します。

import threading 

print "Press Escape to Quit" 

# Global variable 
data = None 

class threadOne(threading.Thread): #I don't understand this or the next line 
    def run(self): 
     self.setup() 

    def setup(self): 
     global data 
     print 'hello world - this is threadOne' 

     with lock: 
      print "Thread one has lock" 
      data = "Some value" 


class threadTwo(threading.Thread): 
    def run(self): 
     global data 
     print 'ran' 
     print "Waiting" 

     with lock: 
      print "Thread two has lock" 
      print data 

lock = threading.Lock() 

threadOne().start() 
threadTwo().start() 

グローバル変数dataの使用。

最初のスレッドは、ロックを取得して変数に書き込みます。

第2のスレッドは、データを待って印刷します。

更新

あなたの周りに渡されるメッセージを必要とする以上の二つのスレッドを持っている場合、threading.Conditionを使用することをお勧めします。