Resultados da pesquisa a pedido "producer-consumer"
Como agregar os dados de um produtor assíncrono e gravá-los em um arquivo?
Estou aprendendo sobre padrões assíncronos / aguardados em c #. Atualmente, estou tentando resolver um problema como este: Há um produtor (um dispositivo de hardware) que gera 1000 pacotes por segundo. Eu preciso registrar esses dados em um ...
Como o reequilíbrio do consumidor funciona em Kafka?
Quando um novo consumidor / colaborador é adicionado ou desativado, o Kafka aciona uma operação de reequilíbrio. O Kafka Rebalancing é uma operação de bloqueio. Os consumidores da Kafka são bloqueados enquanto uma operação de reequilíbrio está em ...
Consumir do Kafka com falha O Iterator está no estado de falha
Estou recebendo exceção ao consumir as mensagens do kafka. org.springframework.messaging.MessagingException: Consuming from Kafka failed; nested exception is java.util.concurrent.ExecutionException: java.lang.IllegalStateException: Iterator is ...
Gerenciando a comunicação assíncrona: como examinar a resposta recebida em outro encadeamento
Eu tenho um thread de expedidor e um de ouvinte. Quando envio um comando, desejo aguardar uma resposta antes de enviar o comando de acompanhamento. Além disso, preciso examinar a resposta antes de prosseguir com o segundo comando, o mínimo dos ...
Java: Passagem de mensagens de alto desempenho (produtor único / consumidor único)
Eu fiz inicialmente esta perguntaaqui [https://stackoverflow.com/questions/3367192/java-is-while-true-loop-in-a-thread-bad-whats-the-alternative] , mas percebi que minha pergunta não é sobre um loop while-true. O que eu quero saber é: qual é a ...
Consumo de mensagens baseado em eventos da API RabbitMQ C #
while (true) { BasicDeliverEventArgs e = (BasicDeliverEventArgs)Consumer.Queue.Dequeue(); IBasicProperties properties = e.BasicProperties; byte[] body = e.Body; Console.WriteLine("Recieved Message : " + Encoding.UTF8.GetString(body)); ...
scolhendo uma estrutura de dados para uma variante do problema do consumidor produtor
gora, eu tenho uma fila, com vários produtores e um único consumido A operação do encadeamento do consumidor é lenta. Além disso, o consumidor leva o elemento da fila através de uma operação de espiada e, até que a operação de consumo seja ...
ila de trabalhos como tabela SQL com vários consumidores (PostgreSQ
Tenho um problema típico de produtor-consumidor: s aplicativos produtores múltiplos gravam solicitações de trabalho em uma tabela de trabalho em um banco de dados PostgreSQ As solicitações de trabalho têm um campo de estado iniciado que ...
Implementando o padrão Produtor / Consumidor em C #
Como posso implementar o Produtor / Consumidoradrões @ em C # usandoEventos e Delegados? O que eu preciso para ficar de olho quando se trata de recursos ao usar esses padrões de design? Há algum caso extremo que eu precise conhecer?
Como iterar itens Queue.Queue no Python?
Alguém conhece uma maneira pitônica de iterar sobre os elementos de umQueue.Queue se removendo-os da fila. Eu tenho um programa do tipo produtor / consumidor em que itens a serem processados são transmitidos usando umQueue.Queue e quero poder ...