[python] 用户增长量统计项目实现过程踩坑总结

import types
import copy_reg

def _pickle_method(m):
if m.im_self is None:
    return getattr, (m.im_class, m.im_func.func_name)
  else:
  return getattr, (m.im_self, m.im_func.func_name)

def __init__(self):
self.__result = []
def result_collector(self, result):
self.__result.append(result)

t_objs = []
for i in range(100):
t = threading.Thread(target=self.batch_send_pika,args=(set_key, redis_port, all_batch_message[i]))
t.start()
t_objs.append(t)
for t in t_objs:
t.join() #等待线程的执行结果

from multiprocessing import Queue,Manager
q_list = []
for i in range(len(rule_list)):
q_name = "q" + str(i)
manager = Manager()
q_name = manager.Queue()
  q_list.append(q_name)