Python 3.14 Executor.map buffersize fun awọn ẹgbẹ́ proxy títóbi

max_workers=8 ń dín àwọn ìdì ìṣiṣẹ́ kù. Ṣùgbọ́n kò dá ìdì ìfiṣẹ́ lọ́tọ̀ dúró láti dá Future fún gbogbo ibi ìparí nínú ìwọlé ńlá.

Python 3.14 fi àṣàyàn ìkàwé ṣáájú tí ó ní ààlà kún:

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 ni ìwádìí ìbáṣepọ̀ tí ó wà pẹ̀lú àwọn àkókò nẹ́tíwọ́kì àti ìmọ́tótó; record_result ń ṣàkóso àkíyèsí tí ó dá padà. Àwọn iye 8 àti 24 jẹ́ ìsúná àpẹẹrẹ. àkójọ proxy ọ̀fẹ́ ń pèsè àwọn olùdíje gbangba fún àwọn ibi ìparí; pa ìlànà wọn mọ́ pẹ̀lú gbogbo àdírẹ́sì kí check_proxy lè lo ọ̀nà gbígbé tí ó tọ́.

Nígbà tí búfà ìfiṣẹ́ kún, map ń dá ìṣàmúlò ohun tí ó ṣeé tún ṣe dúró títí àwọn èsì yóò fi jáde. Èyí tún kan àwọn olùdá.

map ṣì ń fúnni ní ìtòlẹ́sẹẹsẹ ìwọlé: ìwádìí àkọ́kọ́ tí ó lọ́ra lè di àwọn èsì tí ó ti parí mọ́ àti dí ìwọlé síwájú. Fún ìṣiṣẹ́ ní ìtòlẹ́sẹẹsẹ ìparí, lo àpapọ̀ futures tí ó ní ààlà tí ó ṣe kedere tí a ń tún kún bí wọ́n ṣe ń parí.

Ṣàkóso àwọn ìkùnà nẹ́tíwọ́kì tí a retí nínú ìwádìí tí ẹgbẹ́ yóò bá ń fún èsì lọ́wọ́. Ìyàtọ̀ tí a kò ṣàkóso ni a gbé sókè nígbà tí a bá gbé ohun yẹn. chunksize nínú ThreadPoolExecutor kò pèsè ìsúná ìfiṣẹ́ yìí, àwọn ẹ̀dà Python àtijọ́ kò sì ní buffersize.