我怎麼能在Python

Question

從線程sublassing時通過自定義函數我有這樣的代碼

class MyTh(threading.Thread): 

    def __init__(self, group=None, target=None, name=None, 
       args=(), kwargs=None, verbose=None): 
     threading.Thread.__init__(self, group=group, target=target, name=name, 
            verbose=verbose) 
     self.args = args 
     self.kwargs = kwargs 
     return 

    def run(self): 
     logging.debug('running with %s and %s', self.args, self.kwargs) 
     return 

def my_func(): 
    print 'Everything OK' 

當我做到這一點

t1 = MyTh(name='Thread '+ str(i), target=myfunc, args=("test",), kwargs={'a':'A', 'b':'B'}) 
    t1.start() 

我的目標函數是不是在所有調用。我怎麼能讓我的線程調用目標中給出的默認功能

Answer 1

通過重寫run()方法，你搞砸了標準run()並且永遠不會調用目標。你需要做的是要麼不覆蓋的方法或重寫它像這樣：

def run(self): 
    logging.debug('running with %s and %s', self.args, self.kwargs) 
    super(MyTh, self).run() 
    return 

這樣的標準Thread.run也被稱爲並執行target。

此外，您還沒有將args和kwargs傳遞給Thread的構造函數。您需要有：

threading.Thread.__init__(self, group=group, target=target, name=name, 
           verbose=verbose, args=args, kwargs=kwargs) 

爲了正確設置它們。然後你就可以改變你的my_func到：

def my_func(arg1, a, b): 
    print arg1, a, b 
    print 'Everything OK' 

此外，MyTh的構造和Thread.__init__電話是不必要的長。這是很多短，可讀：

def __init__(self, *args, **kwargs): 
    threading.Thread.__init__(self, *args, **kwargs) 
    self.args = kwargs['args'] 
    self.kwargs = kwargs['kwargs'] 

通知您傳遞給構造args和kwargs如何實際上訪問的kwargs['args']和kwargs['kwargs']