Здравствуйте, TK, Вы писали:

TK>Здравствуйте, gandjustas, Вы писали:

TK>>>Небольшой тест на использование TPL и тому подобных библиотек и что будет если агентов будет мало или слишком много...
TK>>>Идея простая: данные падают в очередь там разбираются на n воркеров, после обработки (5ms) каждым воркером сливаются обратно.

G>>Правильно понял, что весь код можно на .net сделать так:
TK>Что тут сказать... Фазу map освоили. Reduce где???
Ты о чем? Reduce — тупо сумма.

G>>Количество реальных воркеров в любом случае система выбирает, поэтому нет смысла делать воркеры разными, если они все делают одно и то же.
TK>В исходном коде Reduce возвращает интерфейс для общения с нодой в кластере (пушим в неё данные, потом забираем ответ). Каждая нода стоит $$$ — что значит система выберет сколько ей нужно???
Прости, а что ты пытаешься сравнить? Если у тебя ноды в кластере, то на передачу данных времени уйдет на три порядка больше, чем на работу кода по этой самой передаче.

TK>Где вообще все это в вашем коде? по коду же понятно, что на выходе будет исходное число и итераций — его и надо было хардкодить.
Нигде, это и не нужно вообще. В твоем коде тоже нету отдельных нод.

Если бы это были отдельные физические ноды, то код и библиотеки были бы совсем другие на обоих языках.
Например для .NET это будет https://dotnet.github.io/orleans/ или (возможно) Akka.NET, а вовсе не Dataflow.