Resultados da pesquisa a pedido "queue"
Implementando uma fila baseada em arquivo
Eu tenho uma fila limitada na memória na qual vários threads enfileiram objetos. Normalmente, a fila deve ser esvaziada por um único thread do leitor que processa os itens na fila. No entanto, existe a possibilidade de a fila estar cheia. Nesse ...
Listas de diferenças no Prolog e variáveis mutáveis
As listas de diferenças são um meio de "contornar" o fato de que variáveis são imutáveis no prólogo? I.e. se eu implementar anexar usando listas de diferenças: diff_append(OpenList, Hole, L2) :- Hole = L2.E então execute: X=[a,b,c|Hole], ...
Como você passa uma referência de fila para uma função gerenciada por pool.map_async ()?
Desejo que um processo de longa execução retorne seu progresso em uma Fila (ou algo semelhante) que alimentarei em um diálogo da barra de progresso. Eu também preciso do resultado quando o processo estiver concluído. Um exemplo de teste aqui ...
Fila push do NodeJS, consumida pelo trabalhador do Laravel
Estou tentando consumir mensagens enviadas ao SQS por um aplicativo de nó. Portanto, a ação "push" é executada pelo Node App no servidor A, a ação "listen" do Laravel App no servidor B. Meu problema: não sei como formatar a carga útil a ser ...
PostgreSQL - implementando uma fila confiável
Estou tentando implementar uma fila confiável com vários gravadores e vários leitores usando o banco de dados postgres. Como evitar linhas ausentes quando um leitor de fila varre uma tabela e as transações em andamento são confirmadas após a ...
Implementar um tipo de fila em F #
Estou tentando implementar uma fila em F # até agora é o que tenho, mas acho que está agindo mais como uma pilha: type 'a queue = NL| Que of 'a * 'a queue;; let enque m = function |NL -> Que(m, NL) |Que(x, xs) -> Que(m, Que(x, xs));; let rec ...
Como capturar detalhes da fila de tarefas após a conclusão no Laravel 5.1?
No Laravel 5.1, eu gostaria de ser notificado quando um trabalho for concluído, com detalhes sobre o trabalho (especificamente, ouser_idecustomer_id) Estou usando oQueue::after método método noAppServiceProvider como o ...
Como enviar carga JSON para RabbitMQ usando o plugin da web?
eu tenho umInstância RabbitMQ 3.4.2 [https://www.rabbitmq.com/]com um plug-in de gerenciamento da web instalado. Quando eu envio a mensagem{'operationId': 194} para a fila usando o Pythonkombu [https://pypi.python.org/pypi/kombu]pacote de fila, ...
Fila de bloqueio Java contendo apenas elementos exclusivos
mais ou menos como um "conjunto de bloqueio". Como posso implementar uma fila de bloqueio em que a adição de um membro que já está no conjunto é ignorada?
Usando interfaces para criar uma fila para tipos arbitrários
Como exercício de aprendizado do Go, estou escrevendo uma estrutura básica de dados da Fila. Ontem, comecei a aprender sobre interfaces. Achei legal tentar usá-las neste exercício. O que estou tentando realizar é ter umQueue que pode aceitar ...