デコレータ付きスレッド

Question

私はアプリケーションにデコレータを使ってスレッドを実装しようとしていますが、ロックやスレッドの管理については理解できません。

1. 私が理解したよう

   import threading 
   
   def run_in_thread(fn): 
       def run(*k, **kw): 
        t = threading.Thread(target=fn, args=k, kwargs=kw) 
        t.start() 
       return run 
   
   class A: 
       @run_in_thread 
       def method1(self): 
        for x in range(10000): 
         print x 
   
   
       @run_in_thread 
       def method2(self): 
        for y in list('wlkefjwfejwiefwhfwfkjshkjadgfjhkewgfjwjefjwe'): 
         print y 
   
       def stop_thread(self): 
        pass 
   
   c = A() 
   c.method1() 
   c.method2() 
   

   は、法1と方法2が同期されていないが、その原料の同期は、ロックの助けを借りて実現しています。デコレータ機能にロックを追加する方法は？

2. デコレータを使用して長いスレッドを停止する方法をどうすれば実現できますか？

Answer 1

あなたがスレッドをより細かく制御することができます：あなたは、

c = A() 
t1 = c.method1() 
t1.join() # wait for it to finish 
t2 = c.method2() 
# ... 

Answer 2

1. あなたはシンプルな内装の機能ではなく、デコレーター自身の内側のロックを追加する必要がある2つのスレッドを同期したい場合。

2. スレッドを直接停止する簡単な方法はありませんが、終了する必要があるスレッドに通知するためにイベントを使用する方法があります。

スレッドデコレータの場合は、pebbleをご覧ください。

def run_in_thread(fn): 
    def run(*k, **kw): 
     t = threading.Thread(target=fn, args=k, kwargs=kw) 
     t.start() 
     return t # <-- this is new! 
    return run 

を使用して

Answer 3

を行うことができますたぶんセマフォがデコレータに役立つ可能性があり、このような何か - 1〜1000階乗の数字を計算します：

import threading 

from functools import wraps 
from math import factorial 


DIC = {} 

def limit(number): 
    ''' This decorator limits the number of simultaneous Threads 
    ''' 
    sem = threading.Semaphore(number) 
    def wrapper(func): 
     @wraps(func) 
     def wrapped(*args): 
      with sem: 
       return func(*args) 
     return wrapped 
    return wrapper 

def async(f): 
    ''' This decorator executes a function in a Thread''' 
    @wraps(f) 
    def wrapper(*args, **kwargs): 
     thr = threading.Thread(target=f, args=args, kwargs=kwargs) 
     thr.start() 
    return wrapper 

@limit(10)  # Always use @limit as the outter decorator 
@async 
def calcula_fatorial(number): 
    DIC.update({number: factorial(number)}) 

@limit(10) 
def main(lista): 
    for elem in lista: 
     calcula_fatorial(elem) 


if __name__ == '__main__': 
    from pprint import pprint 
    main(range(1000)) 
    pprint(DIC)