Articles of cola de

¿Pueden los hilos de Python acceder a las variables en el espacio de nombres?

Tengo una secuencia de comandos que crea un montón de subprocesos, ejecuta un progtwig para usar los subprocesos para ejecutar tareas desde una cola y devuelve algo de cada subproceso. Quiero contar cuántos de estos devolvieron con éxito, así que configuro una variable “exitoso = 0” y la incrementé cada vez que la cola informa […]

como hacer una cola en python

Hola ¿Cómo hacer una copia en profundidad de una cola en Python? Gracias

Multiprocesamiento de Python: RuntimeError: “Los objetos de cola solo deben compartirse entre procesos a través de la herencia”

Soy consciente de multiprocesamiento.Manager () y cómo se puede utilizar para crear objetos compartidos. En particular, colas que pueden ser compartidas entre los trabajadores. Hay esta pregunta , esta pregunta , y esta pregunta . Sin embargo, estos enlaces no mencionan por qué podemos usar la herencia para compartir entre procesos. Según tengo entendido, en […]

Problemas al mezclar hilos / procesos en python

Estoy empezando a intentar hacer cosas multiproceso / multiprocesador y me encuentro con algunos problemas. Lo que quiero hacer es generar una serie de solicitudes de datos que deben descargarse de una base de datos remota. Estos se almacenan en un Queue.Queue (llamémoslo in_q). Una vez que he generado todas las solicitudes, inicie un número […]

Comunicando el final de la cola

Estoy aprendiendo a usar el módulo de Cola, y estoy un poco confundido acerca de cómo se puede hacer que un subproceso de consumidor de la cola sepa que la cola está completa. Idealmente, me gustaría usar get() desde el subproceso del consumidor y hacer que lance una excepción si la cola ha sido marcada […]

Enviar mensaje de un solo sentido a todos los hilos en Python

Necesito enviar información a cada subproceso que se está ejecutando en mi progtwig, y ​​cada subproceso tiene que procesar esa información. No puedo hacerlo usando una cola regular, porque de esa manera, una vez que un hilo elimina los datos de la cola, todos los demás hilos ya no podrán verlo. ¿Cuál es la mejor […]

Python cómo matar los hilos bloqueados en la cola con señales?

Comienzo un montón de hilos trabajando en una cola y quiero matarlos cuando envío el SIGINT (Ctrl + C). ¿Cuál es la mejor manera de manejar esto? targets = Queue.Queue() threads_num = 10 threads = [] for i in threads_num: t = MyThread() t.setDaemon(True) threads.append(t) t.start() targets.join()

Implementar una cola usando dos stacks de Python

He estado repasando algunas de las muchas preguntas de la entrevista de encoding. Me preguntaba cómo harías para implementar una cola usando dos stacks en Python. Python no es mi lenguaje más fuerte, así que necesito toda la ayuda que pueda obtener. Al igual que las funciones de cola, salida y salida.

threadth de python Productor-consumidor de cola con thread-safe

Estoy utilizando subprocesos y cola para recuperar la URL y almacenar en la base de datos Sólo quiero un hilo para hacer el trabajo de almacenamiento. Así que escribo el código de la siguiente manera: import threading import time import Queue site_count = 10 fetch_thread_count = 2 site_queue = Queue.Queue() proxy_array=[] class FetchThread(threading.Thread): def __init__(self,site_queue,proxy_array): […]

Python multiprocessing.Queue deadlocks on put and get

Tengo problemas de interlocking con este código: def _entropy_split_parallel(data_train, answers_train, weights): CPUS = 1 #multiprocessing.cpu_count() NUMBER_TASKS = len(data_train[0]) processes = [] multi_list = zip(data_train, answers_train, weights) task_queue = multiprocessing.Queue() done_queue = multiprocessing.Queue() for feature_index in xrange(NUMBER_TASKS): task_queue.put(feature_index) for i in xrange(CPUS): process = multiprocessing.Process(target=_worker, args=(multi_list, task_queue, done_queue)) processes.append(process) process.start() min_entropy = None best_feature = None […]