Результаты поиска по запросу "queue"
RabbitMQ ожидает завершения нескольких очередей
Хорошо, вот обзор того, что происходит: M <-- Message with unique id of 1234 | +-Start Queue | | | <-- Exchange /|\ / | \ / | \ <-- bind to multiple queues Q1 Q2 Q3 \ | / <-- start of the problem is here \ | / \ | / \|/ | Q4 <-- Queues 1,2 and 3 ...
Приводит ли изменение приоритетного элемента очереди к повторению очереди?
У меня есть priority_queue, и я хочу изменить часть его содержимого (значение приоритета), тогда будет ли очередь восстановлена? Это зависит от того, использует ли он push / pop (более вероятно, потому что вам просто нужно «вставить», а не ...
Как правильно обрабатывать (в Python) IOError: [Errno 4] Прерванный системный вызов, вызванный multiprocessing.Queue.get
Когда я использую multiprocessing.Queue.get, я иногда получаю исключение из-за EINTR. Я точно знаю, что иногда это происходит без уважительной причины (я открываю другую панель в буфере tmux), и в таком случае я хотел бы продолжить работу ...
Потокобезопасная очередь в Java
Я хочу реализовать очередь, которая попадает в несколько потоков. Это стек в одноэлементном классе. Теперь простое решение - это синхронизировать? Я предполагаю, что это понадобится как стандарт? Тем не менее, я хочу расставить приоритеты в ...
Проблема масштабируемости при использовании исходящих асинхронных веб-запросов в IIS 7.5
Немного длинного описания ниже, но это довольно сложная проблема. Я попытался осветить то, что мы знаем о проблеме, чтобы сузить поиск. Вопрос скорее о текущем расследовании, чем об одном вопросе, но я думаю, что это может помочь и другим. Но, ...
Python 2.6 отправляет объект соединения через очередь / канал / и т. Д.
Даноэтот баг (Python Issue 4892) [http://bugs.python.org/issue4892]это приводит к следующей ошибке: >>> import multiprocessing >>> multiprocessing.allow_connection_pickling() >>> q = multiprocessing.Queue() >>> p = multiprocessing.Pipe() >>> ...
Как поставить в очередь фоновые задачи в ASP.NET Web API
У меня есть веб-интерфейс, который предназначен для обработки отчетов в виде очереди. Шаги, которые предпринимает приложение, следующие: Получать контентСопоставить контент с объектом и поместить его в очередьОпрос для ожидающих пунктов в ...
Работать с двумя отдельными экземплярами Redis с Sidekiq?
Добрый день, У меня есть два отдельных, но связанных приложений. У них обоих должны быть свои собственные фоновые очереди(читай: отдельные процессы Sidekiq и Redis), Тем не менее, я хотел бы иногда иметь возможность продвигать рабочие ...
Обработка очереди TPL
В настоящее время я работаю над проектом, и мне нужно поставить в очередь некоторые задания для обработки, вот требование: Задания должны обрабатываться по одномуЭлемент в очереди должен быть в состоянии ждать наПоэтому я хочу что-то похожее ...
Создание BackgroundWorker с очередью
Мне нужно создать очередь и использовать ее с BackgroundWorker. Таким образом, я могу добавить операции, и когда одна из них завершается, начинается в фоновом режиме. Я нашел этот код от Google: public class QueuedBackgroundWorker<T> { public ...