7
ответов
java BlockingQueue не имеет блокирующегося быстрого взгляда?
У меня есть блокирующаяся очередь объектов. Я хочу записать поток что блоки, пока нет объект на очереди. Подобный функциональности, обеспеченной BlockingQueue.take (). Однако, так как я не делаю...
вопрос задан: 24 February 2019 06:56
4
ответа
Политика ThreadPoolExecutor
Я пытаюсь использовать ThreadPoolExecutor для планирования задач, но сталкиваюсь с некоторыми проблемами с его политиками. Вот его установленное поведение: Если меньше, чем потоки corePoolSize работают, Исполнитель...
вопрос задан: 5 August 2010 21:44
4
ответа
ScheduledExecutorService с переменной задержкой
Предположим, что у меня есть задача, которая вытягивает элементы от java.util.concurrent. BlockingQueue и обработка их. общественность освобождает scheduleTask (международная задержка, TimeUnit timeUnit) {scheduledExecutorService....
вопрос задан: 5 October 2009 10:06
3
ответа
Как сразу выпустить потоки, ожидающие на BlockingQueue
Рассмотрите BlockingQueue и несколько потоков, ожидающих на опросе (долго, TimeUnit) (возможно также на на взятии ()). Теперь очередь пуста, и она желаема, чтобы уведомить потоки ожидания, что они могут остановиться...
вопрос задан: 22 July 2010 07:56
2
ответа
очереди заданий производителя/потребителя
Я борюсь с лучшим способом реализовать мой конвейер обработки. Мои производители подают работу к BlockingQueue. На потребительской стороне я опрашиваю очередь, обертываю то, что я вхожу в Выполнимую задачу и отправляю...
вопрос задан: 10 February 2010 00:27
1
ответ
Как работает ThreadPoolExecutor, созданный с помощью конструктора с BlockingQueue < Runnable > в качестве аргумента поставить в очередь Callables?
Конструктор для ThreadPoolExecutor имеет аргумент типа для BlockingQueue как Runnable. Предположим, у меня есть ThreadPoolExecutor, объявленный как этот ThreadPoolExecutor customThreadPool = new ...
вопрос задан: 9 March 2019 23:56
1
ответ
Многопоточное чтение из файла и выполнение runnable
ЧТО? Я пытаюсь создать инструмент, который будет читать текстовый файл и публиковать текст после выполнения строкового преобразования. КАК? Инструмент читает файл по строкам и заполняет ...
вопрос задан: 13 July 2018 19:49
0
ответов
PriorityBlockingQueue в Spring Boot зависает с более чем 9 одновременными запросами
Я обнаружил странное поведение в своем веб-приложении Spring Boot, когда запускаю более 9 одновременных запросов (например, с помощью Apache Bench). PriorityBlockingQueue зависает и не обрабатывает ...
вопрос задан: 16 January 2019 14:15
0
ответов
Целесообразно ли добавлять задачи в BlockingQueue для ThreadPoolExecutor?
В JavaDoc для ThreadPoolExecutor неясно, допустимо ли добавлять задачи непосредственно в BlockingQueue, поддерживающую исполнителя. В документации говорится, что вызов executeor.getQueue () «предназначен ...
вопрос задан: 23 May 2017 12:22
0
ответов
Когда следует использовать SynchronousQueue
new SynchronousQueue ()
new LinkedBlockingQueue (1) В чем разница? Когда мне следует использовать SynchronousQueue против LinkedBlockingQueue с емкостью 1?
вопрос задан: 14 June 2013 07:59
0
ответов
Блокирующая очередь и многопоточный потребитель, как узнать, когда остановиться
У меня есть однопоточный производитель, который создает некоторые объекты задач, которые затем добавляются в ArrayBlockingQueue (который имеет фиксированный размер). Я также запускаю многопоточный потребитель. Он собирается как ...
вопрос задан: 25 April 2013 19:07
0
ответов
Android Looper против BlockingQueue?
Может ли кто-нибудь объяснить, почему кто-то должен использовать функцию Android Looper для создания «конвейерного потока» вместо создания обычного потока, который извлекает задачи из BlockingQueue? На первый взгляд кажется ...
вопрос задан: 18 July 2012 14:08
0
ответов
ArrayBlockingQueue использует одну блокировку для вставки и удаления, а LinkedBlockingQueue использует 2 отдельные блокировки.
Я просматривал исходный код ArrayBlockingQueue и LinkedBlockingQueue. LinkedBlockingQueue имеет putLock и takeLock для вставки и удаления соответственно, но ArrayBlockingQueue использует ...
вопрос задан: 13 June 2012 13:11
0
ответов
Java: Производитель = Потребитель, как узнать, когда остановиться?
У меня есть несколько воркеров, использующих ArrayBlockingQueue. Каждый работник берет один объект из очереди, обрабатывает его, в результате может получить несколько объектов, которые будут поставлены в очередь для дальнейшей обработки. ...
вопрос задан: 3 April 2012 19:20
0
ответов
Java BlockingQueue с пакетной обработкой?
Меня интересует структура данных, идентичная Java BlockingQueue, за исключением того, что она должна иметь возможность пакетировать объекты в очереди. Другими словами, я хотел бы, чтобы производитель мог ...
вопрос задан: 27 February 2012 16:16
0
ответов
Реализация очереди блокировки в Haskell
В java есть хороший пакет java.util.concurrent, который содержит реализацию для интерфейса BlockingQueue. Мне нужно что-то подобное в Haskell, чтобы он мог поддерживать фиксированный размер очереди в ...
вопрос задан: 12 February 2012 11:38
0
ответов
Очередь заполнена, по глубине очереди блокировки, требуется пояснение
При заполнении очереди из содержимого файла, кажется, что глубина никогда не увеличивается, поскольку элементы не добавляются в этой реализации. BlockingQueue q = new ...
вопрос задан: 5 February 2012 18:37
0
ответов
Есть ли в C ++ 11 параллельные контейнеры? [закрыто]
В частности, ищу очередь на блокировку. Есть ли такое в C ++ 11? Если нет, то каковы другие варианты? Я действительно не хочу больше спускаться на уровень потока. Слишком уж ошибка -...
вопрос задан: 18 October 2011 19:27
0
ответов
Будучи асинхронно уведомленным о том, что BlockingQueueue имеет доступный элемент
, мне нужно, чтобы Объект был асинхронно уведомлен, когда BlockingQueueue имеет доступный элемент. Я искал и в Javadoc, и в сети в поисках готового решения, а затем получил (может быть, наивный) ...
вопрос задан: 6 September 2011 10:12
0
ответов
Trådsikkerhed ved BlockingQueues drainTo () -metode
Dokumentation af BlockingQueue siger, at bulkoperationer ikke er trådsikre, selvom den ikke eksplicit nævner metoden drainTo (). BlockingQueue-implementeringer er trådsikre. Alt i kø ...
вопрос задан: 7 July 2011 07:21
0
ответов
Java BlockingQueue многократного размера
Итак, я использую BlockingQueue фиксированного размера [ArrayBlockingQueue] в приложении типа производитель / потребитель, но я хочу, чтобы пользователь мог изменять размер очереди на лету. Проблема в том, что нет ...
вопрос задан: 6 July 2011 16:43
0
ответов
«Закрытие» блокирующей очереди
Я использую java.util.concurrent.BlockingQueue в очень простом сценарии производитель-потребитель. Например, этот псевдокод изображает потребительскую часть: класс QueueConsumer реализует Runnable {@Override ...
вопрос задан: 21 March 2011 13:41
0
ответов
Тупиковая блокировка очереди pthread в C ++ (я думаю)
У меня проблема с pthreads, где Я думаю, что захожу в тупик. Я создал блокирующую очередь, которая, как мне показалось, работает, но после еще нескольких тестов я обнаружила, что если я попытаюсь и ...
вопрос задан: 16 February 2011 16:03