Вопросы по теме 'blockingqueue'
Тысячи потоков, порожденных Java-процессом, почему?
У меня возникла проблема с недавним переходом клиента на Linux (64-разрядную версию) при запуске процесса Java.
Процесс порождает тысячи потоков, большинство из которых имеют идентификатор futex. Я искал фьютекс (быстрый мьютекс пользовательского...
1083 просмотров
schedule
29.05.2023
LinkedBlockingQueue и примитивы
Мне нужна LinkedBlockingQueue, но я передаю ей примитивы. Моя скорость передачи данных для добавления в очередь составляет около 4 мс или 256 точек данных в секунду. Проблема, с которой я сталкиваюсь, заключается в том, что данные начинают...
629 просмотров
schedule
21.09.2022
Существуют ли параллельные контейнеры в С++ 11?
В частности, я ищу очередь блокировки. Есть ли такая вещь в С++ 11? Если нет, то каковы мои другие варианты? Я действительно не хочу больше спускаться на уровень потока. Слишком подвержен ошибкам.
40131 просмотров
schedule
24.01.2023
BlockingQueue против семафора
Если мы хотим реализовать пул ресурсов, такой как пул соединений с базой данных. Какую параллельную коллекцию вы будете использовать? BlockingQueue или Semaphore ?
Для BlockingQueue , как и в шаблоне проектирования производитель-потребитель,...
4644 просмотров
schedule
03.07.2023
Синхронизированная очередь?
У меня есть две темы для онлайн-игры, которую я делаю. Один поток получает два числа X и Y, а другой поток отправляет числа X и Y всем, кто зашел на сервер. В основном мне нужна очередь, которая позволит первому потоку добавить 2D-массив в очередь и...
2159 просмотров
schedule
28.01.2023
Как заблокировать, пока BlockingQueue не станет пустой?
Я ищу способ заблокировать, пока BlockingQueue не станет пустым.
Я знаю, что в многопоточной среде, пока есть производители, помещающие элементы в BlockingQueue , могут быть ситуации, в которых очередь становится пустой, а через несколько...
25543 просмотров
schedule
26.08.2022
ArrayBlockingQueue - действительно ли это Concurrent?
Ни одна операция ArrayBlockingQueue не выполняется параллельно ни с одной из других его операций; они всегда берут один и тот же замок. Даже для метода size() требуется блокировка.
public int size() {
final ReentrantLock lock =...
548 просмотров
schedule
04.01.2023
Как заставить ThreadPoolExecutor увеличивать потоки до максимума перед постановкой в очередь?
Некоторое время я был разочарован поведением ThreadPoolExecutor по умолчанию, которое поддерживает ExecutorService пулы потоков, которые используют многие из нас. Цитата из Javadocs:
Если количество запущенных потоков больше corePoolSize,...
32101 просмотров
schedule
16.11.2022
есть ли очередь блокировки в Java, которая позволяет только заглянуть?
Мне нужна очередь блокировки размером 1, и каждый раз, когда применяется put, она удаляет последнее значение и добавляет следующее. Потребители будут пулом потоков, в котором каждый поток должен прочитать сообщение, когда оно будет помещено в...
216 просмотров
schedule
22.12.2023
Состояние гонки потоков Java с BlockingQueue
У меня есть потенциальное состояние гонки в моем коде Java, который использует BlockingQueue, и я хотел бы знать, как изменить код, чтобы избежать этого:
private static BlockingQueue<FileToFTP> ftpQueue = new...
608 просмотров
schedule
30.06.2022
Блокирующая очередь+Поток+Последовательность выполнения потоков
У меня есть очередь блокировки, которая состоит из моих объектов потока. Для меня важен порядок, в котором формировались эти темы. Также каждый поток связан с ключом. Итак, что я хотел сделать, так это то, что если поток для ключа запущен, все...
627 просмотров
schedule
06.02.2024
Асинхронное выполнение в BlockingQueue
Я использую Java-коллекции BlockingQueue для обработки данных. Текущий код выглядит так
while(true){
if(queue.size() > 0)
handle(queue.take())
}
Есть ли способ (в Java или других средах), где я могу обрабатывать его...
628 просмотров
schedule
10.11.2022
Потребительский блок java blockingqueue в полной очереди
Я пишу небольшую программу для помещения твитов из общедоступного потока Twitter в базу данных HBase. Программа использует два потока: один для сбора твитов, а другой для их обработки. Первый поток использует twitter4j StatusListener для получения...
726 просмотров
schedule
04.08.2022
Странное поведение arrayBlockingQueue с элементами массива
У меня какое-то странное поведение при использовании ArrayBlockingQueue, которое я использую для связи между определенными шагами в приложении Java.
Я использую 1 статическую очередь ArrayBlockingQueue, инициализированную следующим образом:...
154 просмотров
schedule
06.12.2022
Используйте PriorityBlockingQueue с компаратором в ScheduledThreadPoolExecutor
Прежде всего: я уже прочитал следующие два вопроса и их возможные решения:
ScheduledThreadPoolExecutors и настраиваемая очередь
Исполнители Java: как установить приоритет задачи?
Моя дилемма состоит в том, что я хочу использовать...
1015 просмотров
schedule
15.04.2022
Есть ли способ сохранить коллекцию сообщений размером до 1 МБ и записать результат в файл JSON/CSV?
У меня есть блокирующая очередь, которая продолжает получать сообщения через какое-то приложение, теперь в приложении asp.net я попытался использовать очередь и записать вывод в файл CSV/JSON.
Здесь я хочу хранить сообщения размером до 1 МБ,...
74 просмотров
schedule
18.08.2022
C++ Блокировка обработки потоков в очереди
Я написал простой класс, который планирую расширить как часть приложения для программирования клиентских сокетов. Класс включает BlockingQueue (я скопировал код отсюда: C++, эквивалентный BlockingQueue в Java ). Как только я создаю экземпляр...
73 просмотров
schedule
07.10.2022
Как изящно остановить/уничтожить поток с блокирующим вызовом при вызове деструктора С++?
В следующем классе рабочий поток запускается внутри конструктора. У рабочего есть блокирующий вызов очереди.
Он работает, как и ожидалось, но когда объект AsyncQueue выходит за пределы области видимости (по какой-либо причине), вызывается его...
148 просмотров
schedule
09.02.2024
