Articles of cola de

Forma rápida de eliminar algunos elementos de una lista / cola

Este es un seguimiento de una pregunta similar que plantea la mejor manera de escribir for item in somelist: if determine(item): code_to_remove_item Y parece que el consenso fue en algo como somelist[:] = [x for x in somelist if not determine(x)] Sin embargo, creo que si solo está eliminando algunos elementos, la mayoría de los […]

Agregar argumento de tiempo de espera a la cola de python.join ()

Quiero poder unirme a () la clase de Cola, pero el tiempo de espera después de un tiempo si la llamada no ha regresado todavía. ¿Cuál es la mejor manera de hacerlo? ¿Es posible hacerlo subclasificando la cola \ usando metaclase?

¿Cuál es la mejor opción para una cola de tareas (Python 3) en Windows ahora que Celery 4 ha eliminado el soporte de Windows?

Ejecutamos un sitio de Flask bajo IIS en Windows, y para las tareas fuera de proceso usamos Celery. Celery nos ha dado algunos problemas en Windows, pero por ahora estamos satisfechos con la ejecución de la versión 3.1.12, utilizando RabbitMQ / AMQP como back-end, que funciona en Windows. La nueva versión de Celery (4) ha […]

Colas de Tensorflow – Cambio entre el tren y los datos de validación

Estoy tratando de hacer uso de las colas para cargar datos de archivos en Tensorflow. Me gustaría ejecutar la gráfica con datos de validación al final de cada época para tener una mejor idea de cómo va el entrenamiento. Ahí es donde me encuentro con problemas. Parece que no puedo entender cómo hacer el cambio […]

¿Cómo implementar colas de prioridad en Python?

Lo siento por una pregunta tan tonta, pero los documentos de Python son confusos … Enlace 1: Implementación de la cola http://docs.python.org/library/queue.html Dice que la cola tiene un diseño para la cola de prioridad. Pero no pude encontrar la forma de implementarlo. class Queue.PriorityQueue(maxsize=0) Enlace 2: Implementación de Heap http://docs.python.org/library/heapq.html Aquí dicen que podemos implementar […]

Cola de Python y cola de multiprocesamiento: ¿cómo se comportan?

Este código de ejemplo funciona (puedo escribir algo en el archivo): from multiprocessing import Process, Queue queue = Queue() def _printer(self, queue): queue.put(“hello world!!”) def _cmdDisp(self, queue): f = file(“Cmd.log”, “w”) print >> f, queue.get() f.close() en su lugar, este otro ejemplo no: (errormsg: el objeto ‘módulo’ no se puede llamar) import Queue queue = […]

Borrar todos los elementos de la cola

¿Cómo puedo borrar una cola. Por ejemplo, tengo datos en una cola, pero por alguna razón no necesito los datos existentes, y solo quiero borrar la cola. ¿Hay alguna manera? Esto funcionara: oldQueue = Queue.Queue()

Una cola de prioridad genérica para Python

Necesito usar una cola de prioridad en mi código de Python. Buscando algo eficiente, me encontré con heapq . Se ve bien, pero parece estar especificado solo para enteros. Supongo que funciona con cualquier objeto que tenga operadores de comparación, pero no especifica qué operadores de comparación necesita. Además, parece que heapq está implementado en […]

Creación de una cola de prioridad de python

Me gustaría crear una cola de prioridad en Python en la que la cola contenga diferentes diccionarios con sus números de prioridad. Por lo tanto, cuando se llama a una “función obtener”, el diccionario con la prioridad más alta (número más bajo) se retirará de la cola y cuando se llame a “agregar función”, el […]

AttributeError: No se puede encoger el cálculo del objeto local .. function1 utilizando la cola de multiprocesamiento

Tengo el siguiente código usando el progtwigdor y el módulo de multiprocesamiento: def computation(): def function1(q): while True: daydate = datetime.now() number = random.randrange(1, 215) print(‘Sent to function2: ({}, {})’.format(daydate, number)) q.put((daydate, number)) time.sleep(2) def function2(q): while True: date, number = q.get() print(“Recevied values from function1: ({}, {})”.format(date, number)) time.sleep(2) if __name__ == “__main__”: q […]