Resultados da pesquisa a pedido "producer-consumer"
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 ...
Aguarde e notifique em Threads de Consumidor e Produtor
Apenas comecei a aprender multi-threading. Eu tenho 5 produtores e 2 consumidores em vários segmentos. Basicamente, este programa adiciona 100 itens à fila. O produtor deixará de adicionar quando o tamanho da fila for 100. Gostaria que o ...
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?
Sobrecarga de consumidor RabbitMQ
Eu tenho lido sobre os princípios das mensagens AMQP confirma. ( https://www.rabbitmq.com/confirms.html [https://www.rabbitmq.com/confirms.html]) Artigo realmente útil e bem escrito, mas uma coisa em particular sobre os agradecimentos dos ...
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 ...
Thread Java aguarde e notifique
Eu tenho dois threads. O segmento A está puxando alguns elementos da fila e o segmento B está adicionando alguns elementos à fil Eu quero que o segmento A entre no modo de suspensão quando a fila estiver vazi Quando o segmento B adiciona ...
filas de trabalho do produtor / consumidor
Estou lutando com a melhor maneira de implementar meu pipeline de processamento. Meus produtores alimentam o trabalho com um BlockingQueue. No lado do consumidor, pesquiso a fila, envolvo o que recebo em uma tarefa Runnable e a envio a um ...
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 ...