タスクは、クォート ティックをほぼリアルタイムで処理することです (1 秒の遅延)。
現時点では、約 100 の見積もりを処理する必要がありますが、数千に増える可能性があります。私はEM現在、それぞれが 10 個の非同期リクエストを実行し、後で処理するためにデータを PubSub に入れる 10 個のスレッドを実行することを検討しています。
また、 gemでテストCelluloid-IOしています。HTTP
私は正しい道を進んでいますか？実装しようとして失敗したことを GitHub で確認しようとしました。
大量の並列リクエストでは、スレッドの代わりにファイバーを使用することが推奨される場合があります。これは、起動が速く、メモリ使用量が少ないためです。
最も一般的なソリューションはEM-synchronyであり、 EM::Synchrony::Iteratorを使用してジョブのスケジューリングとバランスを取ることができます。
EM-synchronyとの互換性のために、 「em-synchrony/em-http」などの対応するEMライブラリを使用する必要があることに注意してください。
詳細については、このブログ投稿を確認してください。