Resultados da pesquisa a pedido "queue"

1 a resposta

Como posso implementar essa fila distribuída de simultaneidade única em qualquer plataforma MQ?

Atualmente, estou com dificuldades para encontrar uma solução para implementar um tipo específico de fila, que exija as seguintes características: Toda a fila deve respeitar a ordem em que o trabalho foi adicionado.A fila inteira terá uma ...

3 a resposta

limite de tamanho máximo da fila de multiprocessamento é 32767

Estou tentando escrever um programa Python 2.6 (OSX) usando multiprocessamento e quero preencher uma Fila com mais do que o padrão de 32767 iten from multiprocessing import Queue Queue(2**15) # raises OSErrorQueue(32767) funciona bem, mas ...

9 a resposta

Uma fila de prioridade genérica para Python

Eu preciso usar uma fila de prioridade no meu código Python. Procurando algo eficiente, me depareiheapq [http://docs.python.org/library/heapq.html]. Parece bom, mas parece ser especificado apenas para números inteiros. Suponho que funcione com ...

1 a resposta

Fila segura de threads em Java

1 a resposta

Convertendo um objeto deque na lista

Atualmente, busco dados da "lista" do meu armazenamento, "deque" para trabalhar com esses dados. Depois de processar os dados buscados, tenho que colocá-los novamente no armazenamento. Isso não será um problema, desde que eu não seja obrigado ...

4 a resposta

Usando muitos consumidores na Fila SQS

Eu sei que é possível consumir uma fila SQS usando vários threads. Eu gostaria de garantir que cada mensagem será consumida uma vez. Sei que é possível alterar o tempo limite de visibilidade de uma mensagem, por exemplo, igual ao meu tempo de ...

1 a resposta

Como ler dados seriais com multiprocessamento em python?

Eu tenho um dispositivo que gera dados em intervalos irregulares. Quero gravar dados em um CSV em intervalos de 2 segundos. Então, imaginei que o multiprocessamento com uma fila poderia funcionar. Aqui estou tentando passar dados de um processo ...

11 a resposta

Fila de tamanho fixo que remove automaticamente os valores antigos automaticamente após novos enfileiramentos

Estou a usarConcurrentQueueara uma estrutura de dados compartilhada cujo objetivo é manter os últimos N objetos passados para ela (tipo de histórico Assuma que temos um navegador e queremos ter os últimos 100 URLs navegados. Desejo uma fila que ...

8 a resposta

ilas de rosca para manequi

Tenho o que presumo que é um cenário de encadeamento bastante comum: Tenho 100 trabalhos idênticos para concluirTodos os trabalhos são independentes um do outroQuero processar no máximo 15 trabalhos por vez À medida que cada trabalho é ...

8 a resposta

mplementando pilha usando listas vinculad

Qual é a melhor maneira de implementar uma pilha usando listas vinculadas em Jav EDIT: eu definiria melhor como mais eficiente usando código limpo. Eu já usei uma matriz para implementar uma pilha, mas não estou familiarizado com as listas de ...