close

[37]

close

BTC : 3HjDPQFfEizxtSZtMnYfssVb3Ri9eSb1wP

[440]

my dick bends

---

i dont know alot about workers but i use multithreading for account gens. 
this thread may help you

I am currently not selling anything. Beware of impersonators.

[37]

appending a function to a task list using requests will end processing one by one, i need to implement aiohttp with asyn and i have no idea how to do it xD

BTC : 3HjDPQFfEizxtSZtMnYfssVb3Ri9eSb1wP

[1.874]

this isnt asyncio but here
 

Code:

from concurrent.futures import ThreadPoolExecutor
from concurrent.futures import as_completed
def FUNCTION_NAME_HERE(VARIABLE_NAME_HERE):
    print(f"{VARIABLE_NAME_HERE}")

futures = []
executor = ThreadPoolExecutor(max_workers=100)
for file in file_list:
    futures.append(executor.submit(FUNCTION_NAME_HERE, VARIABLE_NAME_HERE))
for future in as_completed(futures):
    try:
        future.result()
    except:
        pass
futures.clear()

@emptyyy is my dad | http://bottersheaven.xyz

[49]

Code:

import asyncio
import aiohttp
from time import time

async def scrape_site(url: str, session: aiohttp.ClientSession = None) -> None:
    session = session or aiohttp.ClientSession()

    async with session.get(url) as res:
        print(f"Request sent to site {url}")

async def main() -> None:
    sites = ["https://youtube.com", "https://google.com", "https://yahoo.com"]

    start = time()
    session = aiohttp.ClientSession()
    await asyncio.gather(*[scrape_site(site, session) for site in sites])
    await session.close()
    print(f"Finished in {time()-start}ms")

if __name__ == "__main__":
    loop = asyncio.get_event_loop()
    loop.run_until_complete(main())

Quick example I made, I hope this helps ?