Из JavaDocs: ConcurrentLinkedQueue является подходящим выбором , когда много потоков будет общий доступ к общей коллекции. Эта очередь не допускает пустых элементов. ArrayBlockingQueue - это классический «ограниченный буфер», в котором массив фиксированного размера содержит элементы, вставленные...
В чем основная разница между стеком и очередью ?? Пожалуйста, помогите мне, я не могу найти разницу. Как отличить стек от очереди? Я искал ответ в разных ссылках и нашел этот ответ .. В программировании высокого уровня стек определяется как список или последовательность элементов, которые...
Мне нужна очередь фиксированного размера. Когда я добавляю элемент и очередь заполняется, он должен автоматически удалять самый старый элемент. Есть ли для этого реализация на...
У меня очередь приоритетов в Java целых чисел: PriorityQueue<Integer> pq= new PriorityQueue<Integer>(); Когда я звоню, pq.poll()я получаю минимальный элемент. Вопрос: как изменить код, чтобы получить максимальный...
Я использую ConcurrentQueueобщую структуру данных, цель которой - хранить последние N переданных ей объектов (своего рода история). Предположим, у нас есть браузер и мы хотим иметь последние 100 просмотренных URL. Мне нужна очередь, которая автоматически удаляет (удаляет из очереди) самую старую...
Закрыто. Этот вопрос не соответствует рекомендациям по переполнению стека . В настоящее время он не принимает ответы. Хотите улучшить этот вопрос? Обновите вопрос, чтобы он соответствовал теме Stack Overflow. Закрыт 4 года назад . Уточните этот вопрос Ищу возможность использовать очередь сообщений...
Мой вопрос относится к заданному ранее вопросу . В ситуациях, когда я использую очередь для связи между потоками производителя и потребителя, люди обычно рекомендуют использовать LinkedBlockingQueueили ConcurrentLinkedQueue? Каковы преимущества / недостатки использования одного над другим? Основное...
Очередь с приоритетом stl по умолчанию - максимальная (функция Top возвращает самый большой элемент). Скажем, для простоты, это очередь приоритетов значений типа...
Возьмем, PriorityQueueнапример, http://java.sun.com/j2se/1.5.0/docs/api/java/util/PriorityQueue.html#offer(E) Может кто - нибудь дать мне пример , Queueгде addи offerметоды различны? Согласно Collectionдокументу, addметод часто стремится обеспечить наличие элемента внутри, Collectionа не добавлять...
Я хочу использовать структуру данных очереди в моей программе Objective-C. В C ++ я бы использовал очередь STL. Какая эквивалентная структура данных в Objective-C? Как мне нажимать / выталкивать...
Некоторое время я был разочарован поведением по умолчанию, ThreadPoolExecutorкоторое поддерживает ExecutorServiceпулы потоков, которые используют многие из нас. Цитата из Javadocs: Если количество запущенных потоков больше corePoolSize, но меньше maximumPoolSize, новый поток будет создан только в...
Каков хороший подход для обработки фоновых процессов в приложении NodeJS? Сценарий : после того, как пользователь отправит что-то в приложение, я хочу обработать данные, запросить дополнительные данные из внешних ресурсов и т. Д. Все это занимает довольно много времени, поэтому я хочу, чтобы это...
А есть ли? На мой взгляд, MB знает как подписчиков, так и издателей и действует как посредник, уведомляя подписчиков о новых сообщениях (по сути, модель «push»). MQ, с другой стороны, больше похожа на модель «вытягивания», когда потребители выбирают сообщения из очереди. Я здесь совсем сбился с...
Какие сообщения можно хранить в очередях RabbitMQ? Только струны? Или я могу выбрать тип, который я хочу сохранить: int, binary, string и т. Д.? Каков максимальный размер одного сообщения? Сколько очередей или обменов можно создать? Или это зависит от мощности сервера?...
Закрыто . Этот вопрос должен быть более конкретным . В настоящее время он не принимает ответы. Хотите улучшить этот вопрос? Обновите вопрос, чтобы он фокусировался только на одной проблеме, отредактировав этот пост . Закрыт 10 месяцев назад . Уточните этот вопрос Все примеры из Кафки |...
В документации к multiprocessingмодулю показано, как передать очередь процессу, запущенному с multiprocessing.Process. Но как я могу разделить очередь с запущенными асинхронными рабочими процессами apply_async? Мне не нужно динамическое объединение или что-то еще, просто способ для рабочих...
Алгоритм Дейкстры был представлен мне следующим образом while pqueue is not empty: distance, node = pqueue.delete_min() if node has been visited: continue else: mark node as visited if node == target: break for each neighbor of node: pqueue.insert(distance + distance_to_neighbor, neighbor) Но я...
Я проверил официальный Android документации / руководство для Looper, Handlerи MessageQueue. Но я не мог этого понять. Я новичок в Android и очень запутался в этих концепциях.
У меня есть несколько очередей с RabbitMQ. Некоторые из них сейчас бесполезны, как их удалить? К сожалению, я не выбрал auto_deleteопцию. Если я установлю сейчас, он будет удален? Есть ли способ удалить эти очереди сейчас?...
NSOperationQueueесть waitUntilAllOperationsAreFinished, но я не хочу его синхронно ждать. Я просто хочу скрыть индикатор прогресса в пользовательском интерфейсе, когда очередь заканчивается. Как лучше всего этого добиться? Я не могу отправлять уведомления с моего NSOperations, потому что я не...