xiaolinjia

@wuwukai007 这个连第一步都失败了，现在总结得出，应该是有个数据库的持续化链接的问题，就是 self.db 。其他的 websocket，rabbitmq，因为都是在进程内创建的都没问题，应该就是剩下这个 oracle 的数据库链接不能 pickle 了

@wuwukai007 socket 这里，我刚才单独测试的时候应该是没问题，因为他是每个进程内，才创建的。应该不会参与序列化这块。。

@hustlibraco 其实我也有想过这个，不过就是单独创建一个实例的话，会多次初始化，但是我又想只初始化一次。

@xiaolinjia 那个空格被吃了，
client = Client()
from multiprocessing import Pool
pool = Pool(processes=2)
for url in ['ws://192.168.0.18:9988/websocket/37', 'ws://192.168.0.18:9988/websocket/44']:
----pool.apply_async(func=client.received_message, args=(url,))
pool.close()
pool.join()

@wuwukai007 我补充了一下问题，我调用的时候是在 main 方法中:
client = Client()
from multiprocessing import Pool
pool = Pool(processes=2)
for url in ['ws://192.168.0.18:9988/websocket/37', 'ws://192.168.0.18:9988/websocket/44']:
pool.apply_async(func=client.received_message, args=(url,))
pool.close()
pool.join()

@wuwukai007 我进程的 args 里面的参数是可以 pickle 的，可能是进程里的类方法里有些类成员不能 pickle。

@wuwukai007 这个 obj 指的是？

import math
a = [-10, -1.67, 1.74, 27.43, -3.4, -0.59, 13.01, 18.69, 0.68, -1.17, 2.96, 13.14, 12.76, -0.14, 12.76, 3, 3, 5, 7, -2, 20]


def function(temp: list, n):
step = math.ceil(len(temp)/n)
temp.sort()
s = slice(0, step)
for i in range(n):
print(temp[s])
s = slice(s.start + step, s.stop + step)

if __name__ == '__main__':
function(a, 6)

pyecharts