希望构建一个python脚本,它可以像for line in sys.stdin:一样从标准输入运行无限读取循环。对于每次迭代,我希望从使用line作为输入在后台执行的池中获取一个worker。完成执行或超时的进程将打印到stdout。
我很难找到一个能够持续工作的工作池模块。例如,只支持像join这样的函数,这些函数等待所有工作进程完成所有任务。对于上面的规范,我不能提前知道所有
代码的灵感来自漏桶算法。代码运行良好,但我发现,当我尝试每隔(少于)1/60秒发送请求时,我开始每分钟收到意外数量的请求(超过10万次)。我假设这个问题可能与asyncio.sleep的精度有关,当参数太小时,它可能被认为等于0。测试操作系统: Windows 10家庭。在Pycharm中测试。loop.run_until_complete(async_ops.async_main()) loop.close()如果我进行以下小的更改,RPS度量客户端将与更高<e