Resultados de la búsqueda a petición "producer-consumer"
El consumo de Kafka falló Iterator está en estado fallido
Recibo una excepción al consumir los mensajes de kafka. org.springframework.messaging.MessagingException: Consuming from Kafka failed; nested exception is java.util.concurrent.ExecutionException: java.lang.IllegalStateException: Iterator is in ...
Administrar la comunicación asincrónica: cómo examinar la respuesta recibida en otro hilo
Tengo un hilo de despachador y un hilo de escucha. Cuando despacho un comando, quiero esperar la respuesta antes de enviar el comando de seguimiento. Además, necesito examinar la respuesta antes de poder proceder con el segundo comando, el menor ...
Espere y notifique en Hilos de consumidores y productores
Acabo de empezar a aprender multihilo. Tengo 5 productores y 2 consumidores en múltiples hilos. Básicamente, este programa agrega 100 elementos a la cola. El productor dejará de agregar cuando el tamaño de la cola sea 100. Me gustaría que el ...
Implementación del patrón de productor / consumidor en C #
¿Cómo puedo implementar la Productor / Consumidor patrones en C # usandoEventos y delegados? ¿Qué debo tener en cuenta cuando se trata de recursos al usar estos patrones de diseño? ¿Hay algún caso límite que deba conocer?
Sobrecarga del consumidor RabbitMQ
He estado leyendo sobre los principios de la confirmación de mensajes AMQP. ( https://www.rabbitmq.com/confirms.html [https://www.rabbitmq.com/confirms.html]) Artículo realmente útil y bien escrito, pero una cosa en particular sobre ...
Elegir una estructura de datos para una variante del problema del consumidor productor
n este momento, tengo una cola, con múltiples productores y un solo consumidor. a operación del hilo @Consumer es lenta. Además, el consumidor toma el elemento de la cola a través de una operación de vistazo, y hasta que se complete la operación ...
Java hilo esperar y notificar a
Tengo dos hilos. El subproceso A extrae algunos elementos de la cola y el subproceso B agrega algunos elementos a la cola. Quiero que el hilo A se vaya a dormir cuando la cola esté vacía. Cuando el hilo B agrega algún elemento a la cola, debe ...
colas de trabajo de productor / consumidor
Estoy luchando con la mejor manera de implementar mi canal de procesamiento. Mis productores alimentan el trabajo a un BlockingQueue. En el lado del consumidor, sondeo la cola, envuelvo lo que obtengo en una tarea Runnable y lo envío a un ...
¿Cómo agregar los datos de un productor asíncrono y escribirlos en un archivo?
Estoy aprendiendo sobre patrones asíncronos / en espera en C #. Actualmente estoy tratando de resolver un problema como este: Hay un productor (un dispositivo de hardware) que genera 1000 paquetes por segundo. Necesito registrar estos datos en ...
RabbitMQ C # API Consumo de mensajes basado en eventos
while (true) { BasicDeliverEventArgs e = (BasicDeliverEventArgs)Consumer.Queue.Dequeue(); IBasicProperties properties = e.BasicProperties; byte[] body = e.Body; Console.WriteLine("Recieved Message : " + Encoding.UTF8.GetString(body)); ...