Büyük proxy partileri için Python 3.14 Executor.map buffersize

max_workers=8 yürütülen iş parçacıklarını sınırlar. Ancak dev bir girdide ayrı bir gönderim döngüsünün her uç nokta için Future oluşturmasını engellemez.

Python 3.14 sınırlı bir ön okuma seçeneği ekler:

from concurrent.futures import ThreadPoolExecutor

with ThreadPoolExecutor(max_workers=8) as executor:
    for result in executor.map(check_proxy, endpoints, buffersize=24):
        record_result(result)

check_proxy ağ süreleri ve temizlik içeren mevcut eşzamanlı denetimdir; record_result döndürdüğü gözlemi işler. 8 ve 24 değerleri örnek bütçelerdir. ücretsiz proxy listesi uç noktalar için genel adaylar sağlar; check_proxy'nin doğru taşımayı kullanabilmesi için protokollerini her adresle birlikte tutun.

Gönderim tamponu dolduğunda map, sonuçlar verilene kadar yinelenebilir nesnenin tüketimini duraklatır. Bu, üreteçler için de geçerlidir.

map hâlâ giriş sırasına göre verir: yavaş bir erken denetim, tamamlanmış sonraki sonuçları tutabilir ve daha fazla girişi geciktirebilir. Tamamlanma sırasına göre işlemek için, bittikçe yenilenen açıkça sınırlı bir futures kümesi kullanın.

Parti sonuç vermeye devam edecekse beklenen ağ arızalarını denetimin içinde ele alın. İşlenmeyen bir istisna o öğe alındığında yükseltilir. ThreadPoolExecutor'daki chunksize bu gönderim bütçesini sağlamaz ve eski Python sürümlerinde buffersize yoktur.