Есть приложение-сервис, в нем создаются потоки для обработки запросов от клиента.

Чего хотелось бы:
из каждого потока добавлять в очередь элементы, которые читаются из очереди в одном постоянно активном месте и обрабатываются, затем пишутся в базу.
Что-то типа по принципу работы логгера.

Как лучше организовать такое?