LinkedBlockingDeque.take() - отдельный экземпляр в потоке

Question

кратной

В нашем многопоточном Java приложение, мы используем LinkedBlockingDeque отдельный экземпляр для каждого потока, предположим, темы (c1, c2, .... C200)

Темы T1 & T2 принимает данные из сокета &, добавляет объект в конкретный потребительский Q от c1 до c200.

Бесконечный цикл внутри прогона(), который вызывает LinkedBlockingDeque.take()

В нагрузку запустить использование процессора для самого javae.exe составляет 40%. Когда мы суммируем другой процесс в системе, общее использование ЦП достигает 90%.

Используя JavaVisualVM бег() принимает больше ресурсов процессора, и мы заподозрить LinkedBlockingDeque.take()

Так пытавшихся альтернативы, как thread.wait и уведомления и Thread.Sleep (0), но без изменений.

Причина, по которой каждый потребитель, имеющий отдельный Q для двух причин, 1.There может быть больше, чем один запрос потребителя c1 от T1 или T2 2.Если мы сбрасывать все REQ в одном д, времени для Seach c1 до c200 будет больше, и критерии поиска будут расширяться. 3.And пусть потребитель имеет отдельный Q для обработки запросов тира

Попытки уменьшить загрузку процессора и нуждается в ваших входах ...

SD

Answer 1

1. сделать профилирование и сделать что методы очереди занимают относительно много процессорного времени. Является ли ваша обработка сообщений настолько простой, что ее сравнивают с отправкой/записью в/из очереди? Сколько сообщений обрабатывается в секунду? Сколько процессоров есть? Если каждый процессор обрабатывает менее 100 тыс. Сообщений в секунду, то вполне вероятно, что причиной является не доступ к очередям, а сама обработка сообщений.

2. Вложение в LinkedBlockingDeque создает экземпляр вспомогательного объекта. И я подозреваю, каждое новое сообщение выделено из кучи, так что 2 создания за сообщение. Попробуйте использовать пул предварительно распределенных сообщений и циклических буферов.

3. 200 потоков слишком много. Это означает, что слишком много переключателей контекста. Попробуйте использовать библиотеки актеров и пулы потоков, например, https://github.com/rfqu/df4j (да, это мое).

4. Проверьте, подходит ли http://code.google.com/p/disruptor/ для ваших нужд.