Секция данных:
static Market market;
// boost::asio::thread_pool thread_pool;
static std::unordered_map < std::string, std::unordered_map < std::string,
std::pair < Market::path_t, std::string > > > data; // future
Настройка Python:
static Python_Initializer python_initializer;
static boost::python::object global = boost::python::import("__main__").attr("__dict__");
boost::python::exec("from analysis.src.main import run", global, global);
static boost::python::object module = global["run"];
В Python_Initializer
вызывается Py_Initialize
. static
здесь и в секции данных нужен для избежания повторного конструирования объектов, т.к. данный код размещается в функции DLL библиотеки, вызываемой в цикле извне. Функция run
является потокобезопасной.
Основное исполнение:
for (const auto & asset : market.assets())
{
for (const auto & scale : market.scales())
{
auto file = market.get(asset, scale, 250);
//std::packaged_task < std::string() > task([asset, scale, file, &module]()
//{
// return boost::python::extract < std::string > (
// module(asset.c_str(), scale.c_str(), file.string().c_str()));
//});
//data[asset][scale] = std::make_pair(std::move(file),
// boost::asio::post(thread_pool, std::move(task)));
std::string message = boost::python::extract < std::string >(
module(asset.c_str(), scale.c_str(), file.string().c_str()));
data[asset][scale] = std::make_pair(std::move(file), std::move(message));
}
}
В текущем последовательном исполнении все работает. Однако, если добавить thread_pool
, обернуть последний std::string
в data
с помощью std::future
и заменить код в основном исполнении на тот, который сейчас закомментирован, то возникнет ошибка. Содержание ее ни о чем конкретном не говорит, ошибка на уровне Boost.Python, если отследить, то проблема с чтением/записью указателей при настройке какой-то callback функции.
Вопрос: как настроить Boost.Python, чтобы через него механизмами параллельного исполнения Boost и стандартной библиотеки можно было параллельно исполнять некоторую потокобезопасную Python функцию?