blockingqueue — все вопросы

1ответ
4 голоса
как дать приоритет темам, ожидающим семафор?
Я использовал семафор, чтобы ограничить число потоков, обращающихся к функции. Я хочу, чтобы поток, который будет пробужден, должен был быть выбран по приоритету, который я буду отдавать, а не по ум
1ответ
4 голоса
Должен ли я явно разбудить поток, сосущий BlockingQueue.take () для производительности?
Я понимаю, что наличие потока, всасывающего элементы BlockingQueue с использованием take() метод будет ожидать доступности элемента (если он не прерван). У меня есть два вопроса: i) Поток ав
3ответа
4 голоса
Блокировка очереди гонки?
Я пытаюсь реализовать высокопроизводительную очередь блокировки, поддерживаемую циклическим буфером поверх pthreads, semaphore.h и gcc atomic buildins. Очередь должна обрабатывать несколько одноврем
4ответа
4 голоса
Вопрос разработки Java BlockingQueue
JavaDoc метода java.util.concurrent.BlockingQueue.add (E e) гласит:логическое сложение (E e)Вставляет указанный элемент в эту очередь, если это можно сделать немедленно, не нарушая ограничения емкости
1ответ
8 голосов
В чем преимущество разветвления потока перед использованием нескольких потоков?
Я читаю Java 8 в действии, и автор ссылается на эту ссылку: http://mail.openjdk.java.net/pipermail/lambda-dev/2013-November/011516.html и пишет свой собственный потоковый формирователь, который
3ответа
11 голосов
Эквивалент канала Голанг на Яве
У меня есть требование, где мне нужно читать из набора очередей блокировки. Очереди блокировки создаются библиотекой, которую я использую. Мой код должен читать из очередей. Я не хочу создавать пото
2ответа
11 голосов
Получать асинхронное уведомление о наличии элемента BlockingQueue
Мне нужно Object, чтобы получать асинхронные уведомления, когда некоторые BlockingQueue есть предмет для передачи. Я искал в Javadoc и в Интернете готовое решение, затем я нашел (возможно, наивно
2ответа
21 голос
Java BlockingQueue take () vs poll ()
При использовании значений из очереди в бесконечном цикле - что будет более эффективным: 1) Блокировка очереди до тех пор, пока значение не станет доступным через take () while (value = queue.t

Популярные теги

security × 330linux × 316macos × 2827 × 268performance × 244command-line × 241sql-server × 235joomla-3.x × 222java × 189c++ × 186windows × 180cisco × 168bash × 158c# × 142gmail × 139arduino-uno × 139javascript × 134ssh × 133seo × 132mysql × 132