blockingqueue

4зной

1ответ

Что может быть причиной блокировки/разблокировки в PriorityBlockingQueue?

Я читал source code of PriorityBlockingQueue в Java, и мне было интересно: почему это tryGrow() метода рилизинга замка приобрел во время предложений() метода, просто делать свое дело не- блокировка, а

java multithreading blockingqueue 2016-12-27

---

0зной

1ответ

Основная тема зависает из-за потребителя BlockingQueue (который, как я думал, был в другом потоке)

У меня есть тест, который блокирует (первый блок кода). У меня есть несколько элементов, которые работают вместе. У меня есть блокирующая очередь, в которую я помещаю события, тогда у меня есть потреб

java multithreading blockingqueue 2016-11-10

---

0зной

1ответ

Проблемы с реализацией BlockingQueue с нуля

Я пытаюсь создать собственный вариант BlockingQueue, основанный на одном из found here. public class ThreadSafeContainer<E> { private Node front; private Node end; private int capacity; private in

java multithreading synchronization blockingqueue 2016-11-10

---

3зной

1ответ

Почему состояние гонки в LogWriter приводит к блокировке производителя? [Параллелизм на практике]

Прежде всего, чтобы избежать вопроса о вопросе как дубликата ребятами, которые не любят читать до конца, я прочитал вопрос Producer-Consumer Logging service with Unreliable way to shutdown . Но он не

java multithreading concurrency shutdown blockingqueue 2017-02-21

---

1зной

1ответ

Неожиданный вывод в ошибке Consumer Producer

У меня есть код, который я пытаюсь запустить, который дает невыясненный результат. Код: import java.util.concurrent.ArrayBlockingQueue; import java.util.concurrent.BlockingQueue; import java.util.co

java blockingqueue 2016-11-20

---

2зной

1ответ

Есть ли способ сделать ros :: spinOnce() вызов определенного числа обратных вызовов из очереди обратного вызова?

Я пишу программу в ROS, которая должна выполнять определенные вычисления после каждой функции обратного вызова. Моя функция обратного вызова в основном подписывается на тему и устанавливает значение п

callback ros blockingqueue 2017-01-12

---

1зной

1ответ

Действительно ли Boost_lockFree_SPSC_queue имеет переменный размер и потери данных?

Привет, я планировал использовать дополнительную SPSC-очередь. У меня должен быть слушатель, который всегда прослушивает входящие сообщения, как только он его получит, поместит сообщение в очередь и в

multithreading c++11 boost blockingqueue 2016-12-07

---