解決python多線程報(bào)錯(cuò):AttributeError: Can't pickle local object問(wèn)題

更新時(shí)間：2020年04月08日 11:06:57 作者：爆破小能手

這篇文章主要介紹了解決python多線程報(bào)錯(cuò):AttributeError: Can't pickle local object問(wèn)題，具有很好的參考價(jià)值，希望對(duì)大家有所幫助。一起跟隨小編過(guò)來(lái)看看吧

報(bào)錯(cuò)信息：

Traceback (most recent call last):
File “D:/flaskProject/test.py”, line 35, in test
pool.apply(self.out, args=(i,))
File “Python37-32\lib\multiprocessing\pool.py", line 261, in apply
return self.apply_async(func, args, kwds).get()
File "\lib\multiprocessing\pool.py”, line 657, in get
raise self._value
File “\Python37-32\lib\multiprocessing\pool.py", line 431, in _handle_tasks
put(task)
File "\Python37-32\lib\multiprocessing\connection.py”, line 206, in send
self._send_bytes(_ForkingPickler.dumps(obj))
File “*\Python37-32\lib\multiprocessing\reduction.py”, line 51, in dumps
cls(buf, protocol).dump(obj)
TypeError: can't pickle _thread._local objects

原類的構(gòu)造函數(shù)：

class threadtest:

def __init__(self, ipList, user, password):
 self.ipList = ipList
 self.httpAuth = HTTPDigestAuth(user, password)
 return

def out(self, i):
 url = "http://" + i + "/name"
 response = requests.get(url, self.httpAuth)
 print(response.text)
 return

def test(self):
 pool = Pool(processes=2)
 for i in self.ipList:
 pool.apply(self.out, args=(i,))
 pool.close()
 pool.join()
 return

if name == ‘main':
ipList = [‘192.168.2.1', ‘192.168.2.2', ‘192.168.2.3', ‘192.168.2.4', ‘192.168.2.5', ]
a = threadtest(ipList, ‘a(chǎn)dmin', ‘a(chǎn)dmin')
a.test()

原因：

在class中對(duì)屬性進(jìn)行初始化使用了其它類返回的句柄進(jìn)行初始化導(dǎo)致，HTTPDigestAuth的返回值不能進(jìn)行序列化，也就是不能作為cls(buf, protocol).dump(obj)的參數(shù)進(jìn)行序列化。

將self.httpAuth = HTTPDigestAuth(httpUser, httpPassword)修改為：

self.httpUser
self.httpPassword

并將函數(shù)HTTPDigestAuth放到類的方法中

修改后：

class threadtest:

def __init__(self, ipList, user, password):
 self.ipList = ipList
 self.user = user
 self.password = password
 return

def out(self, i):
 url = "http://" + i + "/name"
 response = requests.get(url, HTTPDigestAuth(self.user, self.password))
 print(response.text)
 return

def test(self):
 pool = Pool(processes=2)
 for i in self.ipList:
 pool.apply(self.out, args=(i,))
 pool.close()
 pool.join()
 return

if name == ‘main':
ipList = [‘192.168.2.1', ‘192.168.2.2', ‘192.168.2.3', ‘192.168.2.4', ‘192.168.2.5', ]
a = threadtest(ipList, ‘a(chǎn)dmin', ‘a(chǎn)dmin')
a.test()

以上這篇解決python多線程報(bào)錯(cuò):AttributeError: Can't pickle local object問(wèn)題就是小編分享給大家的全部?jī)?nèi)容了，希望能給大家一個(gè)參考，也希望大家多多支持腳本之家。

您可能感興趣的文章: