Resultados de la búsqueda a petición "producer-consumer"
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 ...
¿Cómo hacer que los hilos de trabajo se cierren después de que el trabajo haya terminado en un patrón multiproceso productor-consumidor?
Estoy tratando de implementar un patrón productor-consumidor multiproceso usando Queue.Queue en Python 2.7. Estoy tratando de descubrir cómo hacer que los consumidores, es decir, los hilos de trabajo, se detengan una vez que se haya realizado ...
Error: no se pudo encontrar o cargar la clase principal config.zookeeper.properties
Estoy tratando de ejecutar una aplicación de consumidor productor de muestra usando Apache Kafka. Lo descargué ...
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 ...
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 ...
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 ...
¿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 ...
consumidor / productor en c ++
Este es un problema clásico de c / p donde algunos subprocesos producen datos mientras que otros leen los datos. Tanto el productor como los consumidores comparten un búfer de tamaño constante. Si el búfer está vacío, los consumidores tienen que ...
Cola de bloqueo y consumidor de subprocesos múltiples, cómo saber cuándo parar
Tengo un único productor de hilos que crea algunos objetos de tareas que luego se agregan a unArrayBlockingQueue (que es de tamaño fijo). También comienzo un consumidor multiproceso. Esto se compila como un grupo de subprocesos fijos ...
shmat () está devolviendo un "shmaddr" diferente para el mismo "shmkey"
Aquí está mi configuración ... /* Bounded Buffer item structure */ struct item { int id; /* string index value */ char str[80]; /* string value */ }; /* Structure for the shared memory region */ typedef struct { int debug; /* debug flag */ int ...