Популярные вопросы по тегу QUEUE
Могу ли я как-то разделить асинхронную очередь с подпроцессом?
... писывать в такой Connection. Напротив, обычные 12 файловые объекты, которые пакет subprocess использует 11 в качестве каналов, вообще не представляют 10 проблемы и can easily be used in combination with asyncio. ОБНОВЛЕНИЕ: Я решил исследовать конвейерный 9 подход немного дальше: я преобразовал объекты 8 Connection, возвращаемые multiprocessing ...
Встроенный API максимальной кучи в Python
... щих элементов. Я 3 пробовал выводить оба метода одинаково, оба 2 вывода: [0, 1, 2, 3, 4, 5, 6, 7, 8, 9]. def heapsort(iterable): h = [] for value in iterable: heapq.heappush(h, value) return [heapq.heappop(h) for i in range(len(h))] def heapsort2(iterable): h = [] heapq._heapify_max(h) for value in iterable: heapq.heappush(h, value) return [heapq.he ...
Объявление очереди в c ++
... ошибку 'очередь' не была объявлена 3 в этой области Что мне не хватает? Я, конечно, создал 2 стру ...
Использование Redis для очередей для нескольких приложений Laravel на одном сервере
... тве драйвера очереди. Очевидно, они 4 связаны с разными базами данных. Вопрос 3 в том, будут ли задания, помещенные в очередь 2 красных из промежуточного приложения, мешать 1 производственной ...
Как заставить клиент скачивать очень большой файл, который генерируется на лету
... 1 всю базу данных и создает файл .xls со всеми 10 записями. Затем файл отправляется клиенту. Конечно, время 9 экспорта полной базы данных требует много 8 времени, и запрос скоро завершится с ...
Общая приоритетная очередь для Python
... шо работала для любого объекта с указанным оператором сравнения). В поисках чего-то эффективного 1 я наткнулся на heapq, но: Я ищу что-то более быстрое, чем heapq, которое реализовано на собственном Python, поэтому это не так быстро. Выглядит неплохо, но, похоже, указан только для целых чисел. Я предполагаю, что он работает с любыми объектами, у которых есть операторы сравнения, но не ука ...
ArrayBlockingQueue и добавить vs положить vs емкость
... upon success and throwing an IllegalStateException if this queue is full. Я всегда интерпретировал 25 это утверждение (часть if it is possible to do so immediattely) следующим образом: Если 24 в очереди есть свободная емкость, вставка 23 будет успешной. Если нет пустого места, это 22 не удастся. Но я неправильно понял. В простом 21 случае, когда я решил использовать ArrayBlockingQueue, например, 20 20 элементов (небольшая о ...
Выбор конкретного объекта в очереди (например, просмотр +1)
... в очереди и изменить 5 одно из его значений? прямо сейчас я просто 4 выполняю foreach через очередь, что может 3 быть лучшим решением, но я не знал, есть 2 ли что-то особенное, что вы мо ...
Удалить сообщения в очереди сервисного брокера
... rver 3 Management Studio, но я не хочу удалять 2 всю очередь, только содержимое в очере ...
Разница между местом в <queue> и push
... яснение по поводу std::queue::emplace и std::queue::push . Оба метода добавляют 2 элемент после текущего последн ...
Проверьте, находится ли задание уже в очереди, используя Laravel 5 и Redis
... 12 настоящее время я работаю с Redis и следую 11 официальному руководству Laravel. В моем 10 случае, когда кто-то переходит на домашнюю 9 страницу, задание отправляется в очередь, давайте 8 рассмотрим следующий пример: HomeController index(): public function index() { if(/*condition*/){ //UpdateServer being the job $thi ...
Как остановить / отменить / приостановить / возобновить задачи в очереди GCD
... экраны в нашем приложении. И некоторые 7 экраны должны автоматически возобновляться. Итак, как 6 пройти очередь в iOS? Я имею в виду, что 5 когда пользователь просматривает приложение, мы 4 запускаем фоновый поток в dispatch_queue_t. Но 3 это никогда не останавливается и не возобновляется ...
Структуры данных - рандомизированные очереди
... mber of items on the queue public void enqueue(Item item) // add the item public Item dequeue() // remove and return a random item public Item sample() // return (but do not remove) a random item public Iterator<Item> iterator() // return an independent iterator over items in random order public static void main(String[] args) // unit testing } Уловка зд ...
Python multiprocessing.Queue против multiprocessing.manager(). Queue()
... y: break if __name__ == '__main__': manager = multiprocessing.Manager() # queue = multiprocessing.Queue() queue = manager.Queue() for i in range(5): queue.put(i) processes = [] for i in range(2): proc = multiprocessing.Process(target=worker, args=(queue,)) processes.append(proc) proc.start() for proc in processes: proc.joi ...
Ошибка Python "FileExists" при создании каталога
... 7] File exists Я подозреваю, что это может быть 7 из-за состояния гонки, когда одно задание 6 создает каталог до того, как другое дойдет до него. Это 5 возможно? Если да, то как можно избежать 4 этой ошибки? Я не уверен, что это состояние 3 гонки, поэтому мне было интересно, м ...
Поточно-ориентированная очередь C++ 11
... ret; } } Тем 8 не менее, у меня иногда возникают ошибки 7 segfault внутри блока if (...wait_for(lock, timeout) == std::cv_status::no_timeout) { }, и проверка в gdb 6 показывает, что segfaults возникают из-за 5 того, что очередь пуста. Как это возможно? Насколько 4 я понимаю, wait_for возвращает cv_status::no_timeout только тогда, когда 3 он был уведомлен, и эт ...
Как поставить предметы в приоритетные очереди?
... документации Python Записи с наименьшим 12 значением извлекаются первыми (запись с 11 наименьшим значением - это запись, возвращаемая 10 sorted(list(entries))[0]). Типичным шаблоном для записей является 9 кортеж в форме: (priority_number, data). Похоже, очередь будет отсортирована 8 по приоритету, а не по данным, что не всегда 7 может быть правильным. Предположим, что 6 данные «элемент 2» поставлены в очер ...
Веб-API ядра .NET с обработкой очереди
... помещает в очередь и вернуть отметку о том, что сообщение принято (независимо от его обработки). Также 11 подпрограмма, которая постоянно проверяет 10 очередь и обрабатывает сообщения одно за 9 другим. Согласно требованию, api будет дейс ...
Как мне красиво декодировать неудачные задания Laravel JSON
... \"qwddqwd.io\",\"hostingType\":1}]\";s:7:\"\u0000*\u0000user\";O:45:\"Illuminate\\Contracts\\Database\\ModelIdentifier\":2:{s:5:\"class\";s:8:\"App\\User\";s:2:\"id\";i:1;}s:10:\"connection\";N;s:5:\"queue\";N;s:5:\"delay\";N;s:6:\"\u0000*\u0000job\";N;}"}} Хотелось бы, чтобы строка json была 3 декодирована во чт ...
Реализация очереди на языке Swift
... ет или верный алгоритм для этого? import Foundation class Node<T> { var value: T? = nil var next: Node<T>? = nil var prev: Node<T>? = nil init() { } init(value: T) { self.value = value } } class Queue<T> { var count: Int = 0 var head: Node<T> = Node<T>() var tail: Node<T> = Node<T>() var currentNode : Node<T> = Node<T>() init() ...
Есть ли разница в производительности между объединением соединений или каналов в rabbitmq?
... токами, работающими в очереди, но я не 12 уверен, следует ли мне использовать соединения 11 или каналы в пуле. Я знаю, что мне нужны 10 каналы для фактической работы, но есть ли 9 преимущество в производительности от наличия 8 одного канала на соединение (с точки зрения 7 большей пропускной способности из очереди)? или 6 мне лучше просто использовать одно соединение 5 для ...
Как мне найти полный список доступных очередей крутящего момента pbs?
... S в 4 "типичной" системе Torque MPI? (запрос нашего 3 администратора занимает более 24 часов, и 2 система меняется с постоянной миграцией) (нап ...
Ошибка тайм-аута процесса очереди Laravel
... of 60 seconds. Я знаю, что могу 10 запустить queue:listen с произвольно большим значением 9 тайм-аута, но это не идеально, поскольку 8 я действительно хочу, чтобы время ожидания истекло в 7 том случае, если какой-то процесс на самом деле не отвечает. Я 6 пытался регулярно вызывать set_time_limit(60) в функции, вызываемой 5 заданием, но это не решило мою проблему. Я 4 нашел в сети ветку, в которой упоминается 3 Symfo ...
@Async предотвращает продолжение потока до тех пор, пока другой поток не завершится
... t of bla to execute: " + (after - before) / 1000.0 + " seconds."); } } И класс, который выполняет вычисления: @Service public class Bar { @Async public void executeBla() { System.out.println("Bla!"); } } Это 2 приведет к следующему результату (при условии, что 1 код в Foo выполняется бесконечн ...
Отсортировать очередь в C#
... { typeofChange = changeType; objectType = changeObj; objectID = objectId; } } поток: public class ChangeInfoUploader { static Queue<ChangeInfo> changeInfoQueue = new Queue<ChangeInfo>(); static Thread changeInfoUploaderThread = new Thread(new Thread ...
Amazon SQS Long Polling не возвращает все сообщения
... же включил длинный 12 опрос кода для каждого запроса приема, но 11 все равно не работал. Ниже приведен код, который 10 я использую. AmazonSQSClient sqsClient = new AmazonSQSClient(new ClasspathPropertiesFileCredentialsProvider()); sqsClient.setEndpoint("sqs.us-west-1.amazonaws.com"); Strin ...
Когда использовать очередь через Arraylist
... List, а 5 затем перейду по элементам, начиная с 0-го 4 элемента, я получу элементы в том же порядке, в 3 котором они были добавлены. По сути, это 2 гарантирует поведение ...
Как замедлить или установить заданную скорость на потребителе потока Kafka?
... . Я использую: max.poll.interval.ms=100 а 5 также max.poll.records=20 чтобы получать около 200 сообщений 4 в секунду. Но, похоже ...
Получение индекса элемента в std :: queue по его значению
... и простой способ получить позицию 1 элемента в std::queue по его значению в C++? Например: std::queu ...
Есть ли очередь фиксированного размера, которая удаляет лишние элементы?
... 4 я добавляю элемент и очередь заполняется, он 3 должен автоматическ ...
Как мне хранить функции javascript в очереди, чтобы они в конечном итоге выполнялись
... javascript и хотел 13 бы хранить функции в виде данных в очереди. Таким 12 образом, я могу создавать запросы (вызовы 11 функций) и отвечать на них, когда мне нужно 10 (фактически выполняя функцию). Есть ли способ 9 сохранить функцию как данные, чем-то похожий 8 на .setTimeout("doSomething()", 1000); кроме этого functionQueue.enqueue(doSomething()); Где он будет хранить doSomething() как 7 д ...
Объект "Очередь" не имеет атрибута "размер"
... inue elif decision == "serve": if Lineup.is_empty() == True: print("The lineup is already empty.") continue else: print("%s has been served."%Lineup.peek()) Lineup.dequeue() continue elif (decision == "exit") or (decision == "quit"): bre ...
Доступ к элементам очереди c ++, таким как массив
... жно ли обращаться к элементам очереди 2 как к массиву ...
Запуск нескольких воркеров очереди Laravel с помощью Supervisor
... php artisan queue:listen --timeout=1800 --tries=5 directory=/var/app/current stdout_logfile=/var/app/support/logs/laravel-queue.log logfile_maxbytes=0 logfile_backups=0 redirect_stderr=true autostart=true autorestart=true startretries=86400 EOB Выполнение некоторых 12 задач в очереди может занять около 10 ми ...
Можно ли создать очередь для набора HashMap?
... ая комбинация 9 и ее хеш помещаются в HashMap<String,String>. Теперь в моем потребительском 8 потоке я хочу иметь возможность использовать 7 коллекцию Queue<> на хэш-карте, чтобы мой потребительский 6 поток мог вызывать poll() и т.д., таким обр ...
Итерировать по очереди объектов по порядку
... е 8 я хотел бы перебрать в том порядке, в котором 7 они были помещены в очередь (первый объект 6 помещен в очередь, второй объект помещен 5 в очередь, третий объект ...) Я видел способ 4 сделать это в Интернете, но не уверен, что 3 это гарантирует, что объекты в о ...
Какую реализацию параллельной очереди мне следует использовать в Java?
... - подходящий вариант, когда многие потоки будут иметь общий доступ к общей коллекции. Эта очередь не допускает пустых элементов. ArrayBlockingQueue - классический «ограниченный буфер», в котором массив фиксированного размера содержит элементы, вставленные производителями и извлеченные потребителями. Этот класс поддерживает необязательную политику справедливости для упорядочи ...
Совместное использование множества очередей между процессами в Python
... уществовать способ разделения 24 множества очередей между процессами без 23 явного указания каждой из них в коде. Есть 22 идеи? Изменить Вот базовая схема программы: 1 - загрузить 21 первый модуль, который определяет некоторые ...
Как реализовать стек с push и pop в Dart
... вательских 5 стилей TextStyles для рендеринга текста 4 Flutter. Я знаю, что с помощью стека можно 3 вставлять и извлекать значения. Звучит похоже 2 на Queue, но я не уверен в разнице. Это не 1 р ...
Сельдерей - Задачи, которые нужно выполнять в приоритетном порядке
... tetime.datetime.today() user_list = UserActivity.objects.filter(last_activity_date__gte=today) g = group(update_user_profile.s(i.user.auth.username) for i in user_list) print datetime.datetime.today() print g(user_list.count()).get() Если кто-то 6 попытается выполнить обновление вручную, он 5 войдет в очередь te и будет выполняться 4 вечно. Есть ли способ на ...
RabbitMQ - сообщение о порядке доставки
... ыбрать нового брокера очередей 25 для моего нового проекта. На этот раз мне 24 нужна масштабируемая очередь, поддерживающая 23 pub / sub, и соблюдение порядка сообщений 22 является обязательным. Я прочитал комментарий 21 Алексиса: он пишет: «Действительно, мы думаем, что 20 RabbitMQ обеспечивает более строгий порядок, чем 19 Kafka» Я прочитал раздел о порядке сообщений 18 в документации rabbitmq: «Сообщения могут 17 быть ...
NodeJS, как повторить задание очереди с помощью Bull через определенное время после сбоя этого задания
... notif to main app', 'redis://127.0.0.1:6379'); class sendDepositNotificationToMainApp { constructor(depositSuccess){ return handle(depositSuccess); } } const handle = async (depositSuccess) => { try { //some function here }.catch(e){ //if error retry job here queue.add(new sendDepositNotificationToMainApp(depositSuccess), {delay : 5000}) ...
Параллельное выполнение задач в Python
... аллельно, затем 8 первые две иждивенцы параллельно .. затем 7 последняя иждивенческая Я предпочитаю, чтобы 6 как можно больше задач выполнялось параллельно, я 5 искал некоторые модули в Google, но я надеялся 4 избежать внешних библиотек и не уверен, как 3 метод Queue-Thread может решить мою проблему 2 (возможно, кто-то мож ...
Java: сортировка очереди
... огда я добавляю элемент, я хочу сортировать 3 все внутри. Чаще всего это будет Целое число. Я не 2 слишком знаком с фреймворком коллекций, есть 1 ли простое решение? public class Round<Type> { private Queue<Type> qe; public Ro ...
Атомарное сравнение и свопинг со структурой в Go
... , как 9 описано here. Для этого необходимо использовать 8 атомарный CompareAndSwap, который предлагается 7 в пакете "sync/atomic". Однако я не уверен, каким будет 6 Go-эквивалент следующего псевдокода: E9: if CAS(&tail.ptr->next, next, <node, next.count+1>) где 5 tail и next имеют тип: type pointer_t struct { ptr *node_t count uint } и node имеют тип: type node_t struct { value ...
Исключение Python в потоке Thread-1 (скорее всего, возникло при завершении работы интерпретатора)?
... 12 он РАБОТАЕТ, но работает очень медленно, примерно 11 на <1 кадр / с. поэтому я смотрю на потоки 10 (потому что я хотел добавить его в конце 9 концов) и нашел эту страницу в Очередях 8 - Learning about Queue module in python (how to run it) Я трачу около 15 минут на создание базовой 7 системы, но как только я зап ...
Как собрать элементы потока в очередь?
... (reward -> IntStream.range(0, reward.getOccurencies()).mapToObj(i -> reward)) .collect(Collectors.toList()); Как ви ...
Как провалить задание и заставить его пропустить следующие попытки в очереди в Laravel?
... ic function __construct($to, $text) { $this->to = $to; $this->text = $text; } /** * Execute the job. * * @return void */ public function handle(SomeMessageSender $sender) { if ($sender->paramsAreValid($this->to, $this->text) { $sender->sendMessage($this->to, $this-> ...
Как я могу узнать больше о том, почему мое задание Laravel в очереди не удалось?
... ый 7 файл моего супервизора выглядит так: [program:duplitron-worker] process_name=%(program_name)s_%(process_num)02d command=php /var/www/duplitron/artisan queue:listen database --timeout=0 --memory=500 --tries=1 autostart=true autorestart=true user=duplitron numprocs=20 redirect_stderr=true stdout_logfile=/var/www/duplitron/storage/logs/duplitron-worker.log В моем 6 duplitron-worker.log я заметил, что Failed: Illumin ...
Реализации очереди на основе FIFO?
... ля хранения кучи целых чисел (я не 3 особо возражаю, если это реализация универсальных 2 типов). ...
