Estoy intentando hacer un threading de una funcion la cual hace una peticion get a una pagina ej: google.com. La cosa es que por cada threading que termina y se inicia se esta acumulando ram que no se elimina, hasta ocupar toda la ram disponible en mi pc y crashearla.
he probado:
- cerrar la sesion de requests (
r1.close()
) - usar otra pagina en ves de google.com
- usar otra librería de threading
- hacer un "post" en ves de un get
bueno. Esta es la funcion a la cual le estoy haciendo threading:
def Yahoo2(accounts):
global hits, bads, free, checked, error, cpm, num2
sess = requests.session()
global proxylist, retry
threads, proxy_type, retrys, timeout, Limit, ProxyGrabber, ProxyLink=load_params()
email = accounts.split(":")[0]
password = accounts.split(":")[1]
while True:
if "yahoo" in email or "ymail" in email:
try:
threads, proxy_type, retrys, timeout, Limit, ProxyGrabber, ProxyLink=load_params()
if proxy_type == "http":
scheme = "http"
elif proxy_type == "socks4":
scheme = "socks4"
elif proxy_type == "socks5":
scheme = "socks5"
if not "null" in proxy_type:
proxy = random.choice(proxylist)
count = proxy.count(":")
proxy_form = {'http': f"{scheme}://{proxy}", 'https': f"{scheme}://{proxy}"}
else:
pass
url = "https://google.com"
if not "null" in proxy_type:
r1 = sess.get(url, proxies=proxy_form)
else:
r1 = sess.get(url, timeout=int(timeout), stream=True)
print(r1.text)
break
except Exception as e:
logging.exception("message")
continue
else:
break
y este es mi codigo donde le hago threading a esa funcion
ctypes.windll.kernel32.SetConsoleTitleW('SPECTRE - Multi-Checker | Prees "S" for save reaming')
mainpool = ThreadPool(processes=int(threads))
mainpool.imap_unordered(func=Yahoo2, iterable=accounts)
while True
dentro deYahoo2
si parece que solo iteras una vez? (puesto que hay unbreak
)