线程装饰器[Python]



我正在尝试使用python套接字和线程库创建一个简单的程序。我想使用装饰器自动完成以下过程:

t = threading.Thread(target=function, args=(arg1, arg2))
t.start()

该程序是使用OOP构建的,所以我在主程序中定义了一个子类,以包含所有的装饰器(我在本文中读到过这个方法:https://medium.com/@vaimpushtaev/decorator-inter-python-class-1e74d23107f6(。因此,我有这样的情况:

class Server(object):
    class Decorators(object):
        @classmethod
        def threaded_decorator(cls, function):
            def inner_function():
                function_thread = threading.Thread(target=function)
                function_thread.start()
            return inner_function
    def __init__(self, other_arguments):
        # other code
        pass
    @Decorators.threaded_decorator
    def function_to_be_threaded(self):
        # other code
        pass

但当我尝试运行时,我会得到以下错误:TypeError: function_to_be_threaded() missing one required argument: 'self'。当我调用线程时,我怀疑问题位于零件中。线程(target=function(,它不知何故没有传递整个函数self.function_to_be_Thread。因此,如果你知道如何解决这个问题,请告诉我?。另外,您能告诉我是否有一种方法可以实现一个接受参数的装饰器,该参数将作为args=(arguments_of_the_decorator)传递给Thread类吗?

非常感谢你抽出时间,原谅我的英语,我还在练习

使用*args语法移动参数。换句话说,使用*args将所有位置参数收集为元组,并将其移动为threading.Thread作为args

import threading
import time
class Server(object):
    class Decorators(object):
        @classmethod
        def threaded_decorator(cls, function):
            def inner_function(*args):
                function_thread = threading.Thread(target=function,args=args)
                function_thread.start()
            return inner_function
    def __init__(self, count,sleep):
        self.count = count
        self.sleep = sleep
    @Decorators.threaded_decorator
    def function_to_be_threaded(self,id):
        for xx in range(self.count):
            time.sleep(self.sleep)
            print("{} ==> {}".format(id,xx))
           

>>> Server(6,1).function_to_be_threaded('a')
>>> Server(2,3).function_to_be_threaded('b')
a ==> 0
a ==> 1
a ==> 2
b ==> 0
a ==> 3
a ==> 4
a ==> 5
b ==> 1

另请参阅如何将参数从一个函数传递到另一个函数?

相关内容

  • 没有找到相关文章

最新更新