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

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

VC>>Задачу опиши. То, что в sobjectizer называется диспетчер, в .net является TaskScheduler. Тебе же надо что бы можно было управлять в одном потоке подписчики работали или в разных?

S>(Насчёт сишного довольно точно — как раз там такое и использовал, хотя и самописным решением.)

S>Я в принципе в соседнем комментарии описывал что бы мне хотелось видеть (и Event Aggregator примерно то что я хочу). Насчёт потоков — наверно это не принципиально, долгие задачи всё равно будут запускаться в отдельном потоке, хотя автоматическое распихивание по пулу потоков было бы неплохо. А если эта штука сумеет автоматический роутинг сообщений по ключу — то вообще замечательно.

Покурите все-таки Reactive Extensions. Использовать не обязательно, но мозг прочищаетЪ
Такой пустяк делается на ура.
Используйте мой предыдущий пост как вводную

Messages.Where(m => m.Key == “Some Key”).Subscribe(...)

А нет, давайте мне пачками по 100 штук и не дольше одной секунды

Messages.Where(m => m.Key == “Some Key”).Buffer(TimeSpan.FromSeconds(1), 100).Subscribe(...)

Черт еще одна очередь появилась, давайте объединим

Messages.Where(m => m.Key == “Some Key”)
 .Merge(Messages2.Where(m => m.Key == “Some Key”))
 .Subscribe(...);

Всю документацию разжёвывать не буду, надеюсь как-то задело.