Articles of cola de

Poner varios elementos en una cola de python

Supongamos que tiene items iterables items contienen elementos que deben ponerse en una cola q . Por supuesto que puedes hacerlo así: for i in items: q.put(i) Pero se siente innecesario escribir esto en dos líneas: ¿se supone que eso es pythonico? ¿No hay manera de hacer algo más legible? q.put(*items)

examinando elementos en una cola de python

¿Es posible examinar elementos en una Queue en Python sin llamar a .get() ? Según los documentos, la indexación no está permitida en la cola. Necesito comprobar si el elemento al principio de la cola cumple con alguna condición y, si lo hace, eliminarlo de la cola. De manera similar, necesito verificar si algún otro […]

¿Cómo obtener los resultados de un conjunto de hilos en python?

He buscado aquí sobre cómo hacer threading en python, pero por mucho no he podido obtener la respuesta que necesito. No estoy muy familiarizado con las clases de Python Queue y Threading y por esa razón algunas de las respuestas aquí presentes no tienen ningún sentido para mí. Quiero crear un grupo de subprocesos que […]

Uso de un administrador para actualizar una cola en un multiproceso de Python

Estoy diseñando un código multiprocesamiento de Python para trabajar en una cola que podría actualizarse a lo largo del procesamiento. El siguiente código a veces funciona, o se atasca, o aparece un error Vacío. import multiprocessing as mp def worker(working_queue, output_queue): while True: if working_queue.empty() is True: break else: picked = working_queue.get_nowait() if picked % […]

¿Cuál es la forma correcta de manejar (en python) IOError: Llamada de sistema interrumpida, generada por multiprocessing.Queue.get

Cuando uso multiprocessing.Queue.get, a veces recibo una excepción debido a EINTR. Sé definitivamente que a veces esto sucede sin una buena razón (abro otro panel en un buffr tmux), y en ese caso me gustaría continuar trabajando y volver a intentar la operación. Puedo imaginar que, en algunos otros casos, el error se deba a […]

Cómo implementar una cola FIFO que admite espacios de nombres

Estoy utilizando el siguiente enfoque para manejar una cola FIFO basada en db.Model de Google App Engine ( consulte esta pregunta ). from google.appengine.ext import db from google.appengine.ext import webapp from google.appengine.ext.webapp import run_wsgi_app class QueueItem(db.Model): created = db.DateTimeProperty(required=True, auto_now_add=True) data = db.BlobProperty(required=True) @staticmethod def push(data): “””Add a new queue item.””” return QueueItem(data=data).put() @staticmethod def […]

Cola de Python pierde fugas cuando se llama dentro de un hilo

Tengo un cliente TCP de Python y necesito enviar archivos de medios (.mpg) en un bucle a un servidor TCP ‘C’. Tengo el siguiente código, donde en el subproceso separado estoy leyendo los bloques de archivo de 10K y lo envío y lo hago todo nuevamente en bucle, creo que es debido a mi implementación […]

multiproceso de Python: escribir en el mismo archivo de Excel

Soy nuevo en Python y estoy tratando de guardar los resultados de cinco procesos diferentes en un archivo de Excel (cada proceso se escribe en una hoja diferente). He leído diferentes publicaciones aquí, pero aún no puedo hacerlo ya que estoy muy confundido acerca de pool.map, colas y lockings, y no estoy seguro de lo […]

Una buena cola síncrona persistente en python

No me importan de inmediato las opciones de fifo o filo, pero podría ser bueno en el futuro … Lo que estoy buscando es una forma fácil y rápida de almacenar (en la mayoría de los casos datos o decenas de millones de entradas) en un disco que se puede obtener y colocar mediante múltiples […]

Obtención de las tareas en una barra de tareas de Google App Engine

Sé que puede ver las tareas actualmente en cola y en ejecución en el panel o la consola del servidor de desarrollo. Sin embargo, ¿hay alguna manera de obtener esa lista programáticamente? Los documentos solo describen cómo agregar tareas a la cola, pero no cómo enumerarlos y / o cancelarlos. En python por favor.