Описание тега blockingqueue

Описание тега Вопросы с тегом
Структура данных очереди, которая ожидает (приостанавливает текущий поток), пока очередь не станет непустой при извлечении элемента и чтобы пространство стало доступным в очереди при сохранении элемента.
2 ответа

LinkedBlockingQueue возвращает только один из нескольких потоков

Я сделал класс, который считает слова в заданных файлах в том же каталоге. Поскольку файлы очень большие, я решил добиться подсчета нескольких файлов, используя несколько потоков. При запуске DriverClass, как указано ниже, он застревает в потоке оди…
16 дек '15 в 21:52
0 ответов

Очереди блокировки работают не правильно

Я использую gem sidekiq-limit-fetch для блокировки очередей. мой sidekiq.yml :concurrency: 10 :pidfile: tmp/pids/sidekiq.pid :queues: - promote - generate_file - extract_metadata :blocking: - promote когда я запускаю сервер, я вижу, что работает тол…
05 дек '17 в 07:48
1 ответ

Java - однопотоковый исполнитель

У меня есть очередь блокировки с несколькими производителями и одним потребителем (этого достаточно для постобработки предметов). Производители запускаются по расписанию, которые отправляют задачи в пул исполнителей, а затем задачи добавляются работ…
31 окт '17 в 09:21
1 ответ

Файл копирования Java с читателем и писателем в разных потоках (используя BlockingQueue)

Я пытался сделать Java-программу для копирования файла с читателем в одном потоке и писателем в другом потоке. Программа работает без каких-либо ошибок, но скопированный файл имеет контрольную сумму, отличную от исходного файла. Я не могу найти ошиб…
05 июн '18 в 19:58
2 ответа

Java BlockingQueue блокировка на take(), с небольшим поворотом

У меня есть ситуация, когда у меня есть 2 блокирующие очереди. Сначала я вставляю некоторые задачи, которые я выполняю. Когда каждая задача завершается, она добавляет задачу во вторую очередь, где они выполняются. Итак, моя первая очередь проста: я …
04 янв '12 в 00:52
2 ответа

Почему ArrayBlockingQueue не был заблокирован, когда очередь заполнена

У меня есть простой тест для ArrayBlockingQueue, как показано ниже: public class TestQueue { static class Producer implements Runnable { private ArrayBlockingQueue<Integer> queue; private int index; public Producer(ArrayBlockingQueue<Intege…
12 авг '18 в 09:52
1 ответ

Как я могу реализовать очередь блокировки с примитивными типами?

Существует ли собственная реализация Java, которая использует очередь блокировки с примитивными типами? Если нет, как я могу построить один? Я хочу использовать блокировку очереди без упаковки и распаковки при использовании типов примитивов. Я прове…
06 сен '16 в 09:44
1 ответ

Работа с BlockingQueue и Multithreads. Все темы застряли в ожидании

Я создаю систему, которая будет иметь несколько развертываний комплектов, и у каждого развертывания будет очередь тестовых комплектов. Поскольку я хочу, чтобы тестовые наборы запускались одновременно при развертывании их отдельных пакетов, мне нужно…
12 фев '15 в 23:32
1 ответ

Как получить текущее запущенное задание в очереди блокировки C#?

Я хочу получить текущую задачу, которую я добавляю в очередь блокировки, как это можно сделать? РЕДАКТИРОВАТЬ: я использую этот планировщик приоритетов и добавляю несколько задач с разными приоритетами: public class PriorityScheduler : TaskScheduler…
05 окт '12 в 21:08
0 ответов

BlockingQueue неправильно работает с stringbuilder

Я пытался поставить ряд строк с потоком (скажем, thread1) в BlockingQueue и записать эти элементы в очереди в файл с другим потоком (thread2). Простой производитель - потребительская проблема. Тема 1: while(condition) { queue.add(data); } Тема 2: wh…
24 мар '17 в 11:23
1 ответ

Scala блокирует очередь, заставляя ждать

Я должен реализовать блокировку и синхронизированную очередь в Scala. Если я что-то не пропустил, синхронизация довольно проста, но чтобы моя очередь блокировалась, я мог думать только о том (что работает): def pop() : T = { this.synchronized { _rea…
24 фев '14 в 09:40
1 ответ

BlockingQueue как контейнер, который не допускает дублирование

Я хочу потокобезопасный контейнер, который блокирует вызывающего, пока элемент не станет доступным. Элементы будут добавляться со скоростью 1000 с в секунду в этот контейнер, но не будут израсходованы с той же скоростью. Поэтому я хочу, чтобы контей…
10 июл '15 в 20:59
2 ответа

Как проверить, что дубликаты не добавляются в LinkedBlockingQueue?

Я получаю сообщения от нескольких учетных записей Gmail, используя почтовый API Java. Различные учетные записи обрабатываются разными потоками, и я использую LinkedBlockingQueue хранить электронные письма. Однако я не хочу, чтобы одно и то же письмо…
13 ноя '12 в 17:01
0 ответов

Java BlockingQueue take() против опроса (время, единица измерения)

Я думаю, что по ошибке ребята сравнили take() и poll(), но я обнаружил, что разумно сравнивать take() и poll (время, единицу измерения), так как оба они предоставлены BlockingQueue, и оба они блокируют очередь сообщений, а не Empty, и в случае, если…
28 сен '15 в 19:48
1 ответ

Сообщения, не использованные в конечной точке SEDA с предоставленным экземпляром очереди

В следующем контексте верблюда я настроил конечную точку SEDA с предоставленной ArrayBlockingQueue: <?xml version="1.0" encoding="UTF-8"?> <beans xmlns="http://www.springframework.org/schema/beans" xmlns:xsi="http://www.w3.org/2001/XMLSchem…
03 июн '16 в 21:00
2 ответа

Использование Blocking Collection для доступа к базе данных и загрузки изображений в C#

Я работаю над программой, в которой есть две кнопки на форме. Первый выполняет функцию доступа к базе данных, а другой загружает изображение из базы данных и сохраняет его вместе с 3 копиями изображения (Thumbnail, zoom, small). Код для доступа к ба…
01 апр '14 в 15:45
2 ответа

Сценарий использования очереди блокировки

Я работаю над проектом, в котором я обрабатываю все исключения, захваченные в блоках перехвата, для отправки на сервер с помощью вызова веб-службы. Идея состоит в том, чтобы вообще не блокировать основное приложение при выполнении этой работы. Я чув…
04 фев '16 в 18:41
1 ответ

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

Я пытаюсь построить свой собственный вариант BlockingQueue, основанный на найденном здесь. public class ThreadSafeContainer<E> { private Node front; private Node end; private int capacity; private int size; public ThreadSafeContainer(int capac…
10 ноя '16 в 19:13
3 ответа

Блокировка очереди гонки?

Я пытаюсь реализовать высокопроизводительную очередь блокировки, поддерживаемую кольцевым буфером поверх pthreads, semaphore.h и gcc atomic buildins. Очередь должна обрабатывать несколько одновременных читателей и писателей из разных потоков. Я выде…
05 янв '12 в 06:25
1 ответ

Полагаться на сокет setReceiveBufferSize или использовать BlockingQueue?

Я делаю приложение, которое подразумевает чтение большого количества данных, отправленных на мой сокет. У меня проблема в том, стоит ли мне полагаться на сокет setReceiveBufferSize, помещать туда большое значение, чтобы надеяться, что он соберет все…
25 авг '13 в 11:59