В проекте возникла необходимость реализовать что-то вроде активных объектов. Каждый такой объект обладает собственным состоянием и потоком управления. Кроме того, объекты могут обмениваться асинхронными сообщениями. Объект должен уметь ожидать прихода определенного сообщения. Поток управления может переключаться только в момент ожидания сообщения. Код объекта зачастую делает какое-нибудь числодробление.
Делать это все на C++ явно несколько неудобно, если только не использовать какую-нибудь библиотеку легковесных процессов, однако я такой не нашел. Вопрос в том, как это сделать удобно? Может, можно использовать какой-нибудь другой язык (при том, что остальная часть проекта написана на C++)? Пока что есть только идея взять Ocaml и подкрутить его с помощью camlp4.
Посмотри мою — act-o library.
Она, конечно, далеко не идеальна, но можешь взять ее как некоторую идею, которую потом переработаешь, или можно подкрутить планировщик потоков, чтобы она стала заметно лучше.
Или, если сможешь четко сформулировать пожелания по улучшению, то пиши мне, я помогу, но не обещаю, что точно...
Здравствуйте, Стэн, Вы писали:
С>Посмотри мою — act-o library.
Ага, спасибо. Это как раз то, о чем я писал, что на С++ писать неудобно — на каждое сообщение приходится делать свою функцию, из-за чего "гладкий" поток управления разрывается. Проблемы возникают в случае, если надо ожидать в данный момент определенное сообщение, а не все подряд.
Здравствуйте, Vintik_69, Вы писали:
С>>Посмотри мою — act-o library. V_>Ага, спасибо. Это как раз то, о чем я писал, что на С++ писать неудобно — на каждое сообщение приходится делать свою функцию, из-за чего "гладкий" поток управления разрывается.
Ну, да, есть такое... И конечно, идеально было бы взять язык который изначально разрабатывался для параллельности и/или с поддержкой сопрограмм.
V_>Проблемы возникают в случае, если надо ожидать в данный момент определенное сообщение, а не все подряд.
Не очень понял, в чем именно проблема, но если что, то в act-o можно включать/отключать обработчики во время выполнения программы.
Здравствуйте, Стэн, Вы писали:
С>Ну, да, есть такое... И конечно, идеально было бы взять язык который изначально разрабатывался для параллельности и/или с поддержкой сопрограмм.
Erlang?
Здравствуйте, Cyberax, Вы писали:
С>>Ну, да, есть такое... И конечно, идеально было бы взять язык который изначально разрабатывался для параллельности и/или с поддержкой сопрограмм. C>Erlang?
Возможно, зависит от того, какую задачу решать надо...
Кстати, а как у Erlang с кластеризацией? На нем Google'вский Map-Reduce легко написать/использовать?
Здравствуйте, Стэн, Вы писали:
С>>>Ну, да, есть такое... И конечно, идеально было бы взять язык который изначально разрабатывался для параллельности и/или с поддержкой сопрограмм. C>>Erlang? С>Возможно, зависит от того, какую задачу решать надо... С>Кстати, а как у Erlang с кластеризацией? На нем Google'вский Map-Reduce легко написать/использовать?
Ну как сказать... В Erlang легкость кластеризации является одной из главных фич Есть и распределенная база — "Mnesia" называется (классное название для базы данных, однако).
Здравствуйте, Cyberax, Вы писали:
C>Здравствуйте, Стэн, Вы писали:
С>>Ну, да, есть такое... И конечно, идеально было бы взять язык который изначально разрабатывался для параллельности и/или с поддержкой сопрограмм. C>Erlang?
Не думаю... С одной стороны это будет оверкилл, потому что вытесняющая многозадачность не нужна, общение по сети тоже. Но что более важно, так это как совместить Erlang с числодробилками. Вполне может быть, что это совмещение и съест все прелести Эрланга.
Здравствуйте, Стэн, Вы писали:
С>Ну, да, есть такое... И конечно, идеально было бы взять язык который изначально разрабатывался для параллельности и/или с поддержкой сопрограмм.
Ага, вопрос только какой
V_>>Проблемы возникают в случае, если надо ожидать в данный момент определенное сообщение, а не все подряд. С>Не очень понял, в чем именно проблема, но если что, то в act-o можно включать/отключать обработчики во время выполнения программы.
Ну, я так понимаю, что при этом другие сообщения будут потеряны. К тому же пример не удачный — больше проблем, когда надо в зависимости от пришедшего сообщения делать разные вещи — как receive в эрланге.
V_>Здравствуйте, Андрей Коростелев, Вы писали:
V_>>>В проекте возникла необходимость реализовать что-то вроде активных объектов.
АК>>http://rsdn.ru/Forum/message/1023317.1.aspx
V_>Нативные потоки не подходят — объектов много. К тому же вытесняющая многозадачность и всякие мьютексы не требуются.
Когда известны точки переключения — такое удобно делать на fiber'aх (ConvertThreadToFiber etc). Мы когда-то боролись с дроблением логики в конечных автоматах, решили как раз написанием fiber'ных классов. Получилось очень удобно...
Здравствуйте, Vintik_69, Вы писали:
V_>Добрый день,
Добрый,
V_>В проекте возникла необходимость реализовать что-то вроде активных объектов. Каждый такой объект обладает собственным состоянием и потоком управления. Кроме того, объекты могут обмениваться асинхронными сообщениями. Объект должен уметь ожидать прихода определенного сообщения. Поток управления может переключаться только в момент ожидания сообщения. Код объекта зачастую делает какое-нибудь числодробление.
Есть и распределенная база — "Mnesia" называется (классное название для базы данных, однако).
