Python 线程池执行器的concurrent.futures

Python 线程池执行器的concurrent.futures.Future有时挂起

pythonpython-3.x

Python 线程池执行器的concurrent.futures.Future有时挂起,python,python-3.x,threadpoolexecutor,concurrent.futures,Python,Python 3.x,Threadpoolexecutor,Concurrent.futures,我面临一个问题，来自ThreadPoolExecutor的concurrent.futures.Future有时会挂起，我使用python 3.7，下面是我的代码：import pandas as pdimport concurrent.futuresimport requestsimport timeimport sysfrom urllib3.util.retry import Retryimport osfrom decimal import localcontext, D

我面临一个问题线程池linux，来自ThreadPoolExecutor的concurrent.futures.Future有时会挂起，我使用python 3.7，下面是我的代码：

import pandas as pd
import concurrent.futures
import requests
import time
import sys
from urllib3.util.retry import Retry
import os
from decimal import localcontext, Decimal, ROUND_HALF_UP
from datetime import datetime,timezone ,timedelta
import urllib3
import base64
urllib3.disable_warnings(urllib3.exceptions.InsecureRequestWarning)
class Test:
    out = []
    CONNECTIONS = 200
    f1 = open('D:/NewProxeyUserPass.txt', 'r')
    Proxies= f1.readlines()
    f1.close()
    f2 = open('D:/UserAgents.txt', 'r')
    UserAgents= f2.readlines()
    f2.close()
    MAX_RETRIES = 3
    ExcptionCount= int
    ExcptionCount=0
    BASE_URI = 'https://h.com/session.php'
    def load_url(n):
        Proxy_Port_User_Pass=Test.Proxies[n].split(":")
        useragent=Test.UserAgents[n]
        Proxy_Port_User_Pass[0].strip()
        ProxyIP =Proxy_Port_User_Pass[0].strip()
        ProxyPort =Proxy_Port_User_Pass[1].strip()
        username = Proxy_Port_User_Pass[2].strip()
        password =Proxy_Port_User_Pass[3].strip()
        usrPass = username+":"+password
        b64Val = base64.b64encode(usrPass.encode()).decode()
        Timestamp =int((datetime.utcnow() - datetime(1970,1,1)).total_seconds())
        headers = {
            "user-agent": useragent.strip(),
            "Connection":"close"
            }
        proxies = {
           "http"  :"http://" + username + ":" + password + "@"  +  ProxyIP + ":" + ProxyPort,
           "https" :"https://" + username + ":" + password + "@"  +  ProxyIP + ":" +ProxyPort
           }
        JsonSession = "{'device':'id'}"
        retries = Retry(total=3,
                       backoff_factor=0.1)
        adapter = requests.adapters.HTTPAdapter(max_retries=retries)
        with requests.Session() as session:
           session.mount('https://', adapter)
           session.keep_alive = False
           session.trust_env=False
           ans = session.post(Test.BASE_URI,
                              data=JsonSession,
                              headers=headers,
                              params={"timestamp":Timestamp},
                              proxies=proxies,
                              verify=False)
           return ans.content
    def DoWork():
        with concurrent.futures.ThreadPoolExecutor(max_workers=Test.CONNECTIONS) as executor:
            future_to_url = (executor.submit(Test.load_url, n) for n in range(0,150))
            count=int
            count=1
            ExcptionCount = int
            ExcptionCount = 0
            time1 = time.time()
            for future in concurrent.futures.as_completed(future_to_url):
                try:
                    print( str(count)+" - "+str(future.result())+"\n")
                    count = count +1
                except Exception as exc:
                        ExcptionCount=ExcptionCount+1
                        print("Exception count : "+ str(ExcptionCount) + " - "+str(exc))
        time2 = time.time()
        print(f'Took {time2-time1:.2f} s'+"\n Total Exceptions Count : "+ str(ExcptionCount))
    pass
Test.DoWork()

我找到了这些和但我不知道如何在我的代码中使用它，那么如何防止ThreadPoolExecutor的concurrent.futures.Future挂起，如果你能给我工作代码，谢谢你的帮助

如果我用很少的数字运行for循环，例如150将不会挂起，但如果我以15000（我需要以大量运行它）这样的大数字运行它，将挂起，有什么建议吗？那么，是否有任何方法可以为ThreadPoolExecutor中的每个工作线程设置一个超时来防止挂起？有什么帮助吗？如果我以较小的数字运行for循环，例如150，则不会挂起，但如果我以较大的数字运行它，例如15000（我需要以较大的数字运行），则会挂起，有什么建议吗？那么有没有办法为ThreadPoolExecutor中的每个工作线程设置一个超时来防止挂起？有什么帮助吗？

（编辑：92站长网）

【声明】本站内容均来自网络，其相关言论仅代表作者个人观点，不代表本站立场。若无意侵犯到您的权利，请及时与联系站长删除相关内容!