0

我以这种方式扭曲了一个类:

import Queue
import threading

class MyThread():
    q = Queue.Queue()
    content = []
    result = {}
    t_num = 0
    t_func = None
    def __init__ (self, t_num, content, t_func):
        for item in content:
            self.q.put(item)
        self.t_num = t_num
        self.t_func = t_func

    def start(self):
        for i in range(self.t_num):
            t = threading.Thread(target=self.worker)
            t.daemon = True
            t.start()
        self.q.join()
        return self.result

    def worker(self):
        while True:
            item = self.q.get()
            value = self.t_func(item)
            self.result[item] = value
            self.q.task_done()


x = [5, 6, 7, 8, 9]
def func(i):
    return i + 1

m = MyThread(4, x, func)
print m.start()

它运作良好。如果我设计带有2个或更多参数的函数func,并将这些参数以列表的形式传递给类,如何正确调用函数工作者中的func函数?

例如。

def __init__ (self, t_num, content, t_func, t_func_p):
            for item in content:
                self.q.put(item)
            self.t_num = t_num
            self.t_func = t_func
            self.t_func_p = t_func_p

def func(i, j, k):
m = MyThread(4, x, func, [j, k])
4

3 回答 3

1

您需要使用*args并将**kwargs任意数量的参数传递给函数。

这里有更多信息: http: //www.saltycrane.com/blog/2008/01/how-to-use-args-and-kwargs-in-python/

于 2012-06-11T12:00:45.887 回答
0

也许这可能会有所帮助:

def __init__(self, t_num, content, func, *params):
    func(*params) # params is a list here [param1, param2, param3....]


def func(param1, param2, param3):
# or 
def func(*params): # for arbitrary number of params

m = MyThread(4, x, func, param1, param2, param3....)
于 2012-06-11T11:45:27.637 回答
0

作为一般规则,如果您要将许多参数传递给特定函数,您可以考虑将它们包装到一个简单的对象中,原因是

  1. 如果您需要添加/删除参数,您只需要修改对象,函数本身,方法签名(及其所有引用)将保持不变
  2. 使用对象时,您将始终知道您的函数正在接收什么(如果您在一个团队中工作,这特别有用,会有更多人使用该函数)。
  3. 最后,由于您在其构造函数上控制对象的创建,因此可以确保与对象关联的值是正确的(例如,在构造函数中您可以确保没有空值,或者类型正确) )。

如果您仍然想使用多个参数,请检查 *args 和 **kwargs,尽管我个人不喜欢这样,因为它最终可能会迫使人们阅读函数的源代码才能使用它。

祝你好运 :)

于 2012-09-13T05:58:06.820 回答