は、私は.NETリモート処理からaynchronousコールバックを処理するPythonスクリプトを持って

Question

ダミースレッドで呼び出しからメインスレッドでPythonの機能を実行します。これらのコールバックはダミー（ワーカー）スレッドで実行されます。私のコールバックハンドラの中から、スクリプトで定義した関数を呼び出す必要がありますが、メインスレッドで実行する関数が必要です。

メインスレッドがサーバーにコマンドを送信し、リモート・クライアントです。これらのコマンドの中には、非同期コールバックが発生するものがあります。

基本的に、私は、.NETのInvokeメソッドと同等のものを必要とします。これは可能ですか？

Answer 1

あなたのダミーのスレッドが機能して、あなたのメインスレッドが消費する移入キューを設定する​​クラスを使用します。

import Queue 

#somewhere accessible to both: 
callback_queue = Queue.Queue() 

def from_dummy_thread(func_to_call_from_main_thread): 
    callback_queue.put(func_to_call_from_main_thread) 

def from_main_thread_blocking(): 
    callback = callback_queue.get() #blocks until an item is available 
    callback() 

def from_main_thread_nonblocking(): 
    while True: 
     try: 
      callback = callback_queue.get(False) #doesn't block 
     except Queue.Empty: #raised when queue is empty 
      break 
     callback() 

デモ：

import threading 
import time 

def print_num(dummyid, n): 
    print "From %s: %d" % (dummyid, n) 
def dummy_run(dummyid): 
    for i in xrange(5): 
     from_dummy_thread(lambda: print_num(dummyid, i)) 
     time.sleep(0.5) 

threading.Thread(target=dummy_run, args=("a",)).start() 
threading.Thread(target=dummy_run, args=("b",)).start() 

while True: 
    from_main_thread_blocking() 

プリント：

From a: 0 
From b: 0 
From a: 1 
From b: 1 
From b: 2 
From a: 2 
From b: 3 
From a: 3 
From b: 4 
From a: 4 

、その後ブロック永遠に