ConcurrentQueue вещь хорошая но как правильно прикрутить ManualResetEvent или чтото подобное примеров нет и я немогу сообразить...

ситуация такая много потоков добавляют данные в ConcurrentQueue
один читает из него и записывает в базу

не могу добавить:
один из добавляющих потоков получает особые данные и надо подождать покудо читающий поток добавит в его в базу...

как такое можно сделать???
1) возвращатся к мутексам
2) или заводить ManualResetEvent для каждого добавляющего потока
или ещё чтото?