Matthias Urlichs
Matthias Urlichs
> OK, then I'll give it a go. 👍🏼 > Probably the next feature you want is multiple bridge connections with load balancing. It's on my list... Heh. Not really....
Thanks for the update. Not a problem.
Cool. Standard Debian stable should be fine.
Yeah and I'm eager for some "free" time in which to test the setup I have in mind … I'll try to shovel some hours free next week.
On 28.05.24 08:27, Wiebe Cazemier wrote: > Has the shoveling worked ;)? Still shoveling, unfortunately. Best laid plans and all that *grumble*. -- -- regards -- -- Matthias Urlichs
Incremtal change from pthsem to libev is possible, I did that with knxd. Its github history contains an adapter that allows you to use both concurrently. I don't remember exactly...
A walkthrough for converting a sync protocol to Trio might also make sense. WRT trio-asyncio: maybe simply refer to it. I do need to add some example that shows how...
You're not closing the original `send_chan`. Also you fill your queue first and start the workers afterwards, which in a real program (i.e. with a non-infinite queue) isn't a terribly...
Anyway, why is your code so complicated? Simplified: ``` tasks = deque(range(103)) results = [] async def worker(worker_id, results, receive_chan): async def process(task): await trio.sleep(random.uniform(0, 0.1)) return task async for...
OK, yeah, if you're scraping then your original code makes more sense. ;-) The point is that you should never use an infinite queue. Infinite queues tend to fill memory....