Как однопоточная модель Py4J работает с FastAPI в сценарии с высоким параллелизмом? ⇐ Python

[Anonymous]

Я интегрирую Py4J с приложением FastAPI, где несколько одновременных запросов API должны взаимодействовать с приложением Java. Я прочитал документацию по однопоточной модели Py4J, но у меня есть вопросы по поводу управления соединениями:

• Всегда ли объект client_server.jvm использует тот же поток для запросов, исходящих из одного потока Python? Если да, сохраняется ли такое поведение, когда несколько запросов FastAPI используют один и тот же экземпляр client_server?

Код: Выделить всё

client_server = ClientServer(java_parameters=JavaParameters(address=remote_host))
client_server.shutdown_callback_server()

• Лучше ли использовать один экземпляр ClientServer для разных запросов или мне следует создать новый экземпляр для каждый запрос? Повысит ли пул соединений с несколькими экземплярами ClientServer производительность в сценариях с высоким уровнем параллелизма?
• Если я повторно использую client_server экземпляр в FastAPI для нескольких запросов, сохраняет ли он какие-либо постоянные ресурсы (например, импорт, переменные) между вызовами, которые могут вызвать проблемы? Если тот же поток FastAPI будет повторно использоваться для будущего запроса, останется ли импорт или как он будет собран сборщиком мусора? Существует ли риск возникновения конфликтов при повторном использовании одного и того же экземпляра ClientServer для нескольких запросов?

Код: Выделить всё

jvm = client_server.jvm
java_import(jvm, "")

Если тот же поток FastAPI обрабатывает будущий запрос, сохранится ли импорт? Как этим управляет сборщик мусора? Существуют ли риски конфликтов с повторно используемыми экземплярами ClientServer?
Будем благодарны за любые советы по обеспечению масштабируемости и производительности этой установки!

Подробнее здесь: https://stackoverflow.com/questions/792 ... rrency-sce