Resultados de la búsqueda a petición "producer-consumer"
Cola de trabajos como tabla SQL con múltiples consumidores (PostgreSQL)
Tengo un problema típico de productor-consumidor: as aplicaciones de productores múltiples escriben solicitudes de trabajo en una tabla de trabajo en una base de datos PostgreSQL. Las solicitudes de trabajo tienen un campo de estado que ...
Java: transmisión de mensajes de alto rendimiento (productor único / consumidor único)
Inicialmente hice esta preguntaaquí [https://stackoverflow.com/questions/3367192/java-is-while-true-loop-in-a-thread-bad-whats-the-alternative] , pero me di cuenta de que mi pregunta no se trata de un ciclo verdadero. Lo que quiero saber es, ...
C # productor / consumidor
Recientemente me he topado con una implementación de c # del patrón productor / consumidor. Es muy simple y (al menos para mí) muy elegante.Parece que fue id...
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 ...
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 ...
Generic .Net Producer / Consumer
Estoy jugando con la idea de implementar un par genérico Productor / Consumidor + cola de procesamiento en C # por diversión. La idea es que simplemente puede crear objetos que implementen las interfaces apropiadas IProducer e ...
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 ...
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 ...
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 ...
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 ...