我有一个使用gem activejob-google_cloud_pubsub的Rails ActiveJob 。(简短的用法教程)。我的应用程序已部署到ruby flex环境上的AppEngine。虽然我的应用程序可以按预期运行,但我很难扩展使用Google Cloud PubSub消息的辅助服务。gem的README文档提到了一种从终端而不是Rails应用程序中指定Worker的max_threads的方法。当我阅读gem的源代码时,我看到initialize
worker的接受了该变量max_threads
(默认为内核数)。问题是我看不到如何使用默认配置初始化工作程序,因此我可以增加线程数。
1-如何activejob-google_cloud_pubsub
使用更多线程初始化Worker?
2-不建议使用比计算机中的处理器更多的线程来初始化工作线程?
任何有关如何扩展此类队列处理的输入都将有所帮助。
1-如何使用更多线程初始化activejob-google_cloud_pubsub Worker?
worker.yaml
--max_threads
按照gem自述文件中的说明添加终端标志
runtime: ruby
env: flex
service: <xxx>
entrypoint: bundle exec activejob-google_cloud_pubsub-worker --max_threads=5
...
这将在每个实例中创建5个工作线程。默认值为逻辑核心数。
本文收集自互联网,转载请注明来源。
如有侵权,请联系[email protected] 删除。
我来说两句