class MyThread(对象):
,,,”
,,,多线程,获取返回值
,,,”
,,,def __init__(自我,,func_list=None):
,,,,,,,self.ret_flag =0
,,,,,,,self.func_list =func_list
,,,,,,,self.threads =, []
,,,def set_thread_func_list(自我,,func_list):
,,,,,,,self.func_list =func_list
,,,def ret_value(自我):
,,,,,,,return self.ret_flag
,,,def trace_func(自我,,函数,,* args,, * * kwargs):
,,,,,,,ret =, func (* args,, * * kwargs)
,,,,,,,self.ret_flag +=,后悔
,,,def 开始(自我):
,,,,,,,self.threads =, []
,,,,,,,self.ret_flag =0
,,,,,,,for func_dict 拷贝self.func_list:
,,,,,,,,,,,if func_dict(“参数”):
,,,,,,,,,,,,,,,new_arg_list =, []
,,,,,,,,,,,,,,,new_arg_list.append (func_dict["函数"])
,,,,,,,,,,,,,,,for arg 拷贝func_dict(“参数”):
,,,,,,,,,,,,,,,,,,,new_arg_list.append (arg)
,,,,,,,,,,,,,,,new_arg_tuple =,元组(new_arg_list)
,,,,,,,,,,,,,,,print new_arg_tuple
,,,,,,,,,,,,,,,t =, threading.Thread(目标=self.trace_func, arg游戏=new_arg_tuple)
,,,,,,,,,,,其他的:
,,,,,,,,,,,,,,,t =, threading.Thread(目标=self.trace_func, arg游戏=(func_dict(“函数”)))
,,,,,,,,,,,self.threads.append (t)
,,,,,,,地图(lambda x: x.start (), self.threads)
,,,,,,,地图(lambda x: x.join (), self.threads)
