Resultados de la búsqueda a petición "blockingqueue"

6 la respuesta

¿Hay contenedores concurrentes en C ++ 11? [cerrado

En particular, estoy buscando una cola de bloqueo. ¿Existe tal cosa en C ++ 11? Si no, ¿cuáles son mis otras opciones? Realmente ya no quiero bajar al nivel del hilo. Demasiado propenso a errores.

2 la respuesta

¿Puedo implementar la cola de bloqueo usando Semaphore en Java?

Me pregunto si es posible usar Semaphore para implementar la cola de bloqueo. En los códigos a continuación, utilizo un semáforo para proteger la sección crítica y dos objetos más de semáforo para rastrear la cantidad de espacios vacíos y ...

7 la respuesta

¿Qué hay de malo con mi técnica de monitoreo de sensores?

(por favor, lea ACTUALIZACIÓN 3 al final) Estoy desarrollando una aplicación que funciona continuamente con los sensores del dispositivo, funciona con

3 la respuesta

Equivalente del canal de golang en Java

Tengo un requisito donde necesito leer de un conjunto de colas de bloqueo. Las colas de bloqueo son creadas por la Biblioteca que estoy usando. Mi código tiene que leer de las colas. No quiero crear un hilo lector para cada una de estas colas de ...

2 la respuesta

Seguridad de subprocesos del método drainTo () de BlockingQueue

Documentación de BlockingQueue [http://download.oracle.com/javase/6/docs/api/java/util/concurrent/BlockingQueue.html] dice que las operaciones masivas no son seguras para subprocesos, aunque no menciona explícitamente el método drainTo (). as ...

3 la respuesta

C ++ pthread bloqueo de cola de bloqueo (creo)

Estoy teniendo un problema con pthreads donde creo que estoy llegando a un punto muerto. Creé una cola de bloqueo que pensé que funcionaba, pero después de hacer más pruebas, descubrí que si intento cancelar varios subprocesos que ...

6 la respuesta

Queue Full, en profundidad de la cola de bloqueo, se necesita aclaración

Cuando se llena la cola del contenido del archivo, la profundidad no parece aumentar nunca, ya que los elementos no se agregan en esta implementación. BlockingQueue<String> q = new SynchronousQueue<String>(); ... fstream = ...

7 la respuesta

¿java BlockingQueue no tiene un vistazo de bloqueo?

0 la respuesta

¿Hay alguna manera de mantener una colección de "mensajes" de hasta 1 MB y escribir el resultado en el archivo JSON / CSV

Tengo una cola de bloqueo que sigue recibiendo mensajes a través de alguna aplicación, ahora en la aplicación asp.net intenté consumir la cola y escribir la salida en el archivo CSV / JSON. Aquí quiero retener mensajes de hasta 1 MB que se ...

12 la respuesta

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 ...