Articles of multiproceso 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 […]

Procesamiento de archivos multihilo Python

Tengo pocos archivos que residen en un servidor, estoy intentando implementar un proceso de subprocesos múltiples para mejorar el rendimiento, leo un tutorial pero tengo pocas preguntas para implementarlo. Aquí están los archivos, filelistread = [‘h:\\file1.txt’, \ ‘h:\\file2.txt’, \ ‘h:\\file3.txt’, \ ‘h:\\file4.txt’] filelistwrte = [‘h:\\file1-out.txt’,’h:\\file2-out.txt’,’h:\\file3-out.txt’,’h:\\file4-out.txt’] def workermethod(inpfile, outfile): f1 = open(inpfile,’r’) f2 = open(outfile,’w’) x […]

Python: Actualizar la variable local en un proceso paralelo desde el progtwig principal

Soy relativamente nuevo en la progtwigción, y lo que pido puede ser una tarea que no es posible. Lo que quiero hacer es iniciar un proceso paralelo, que se ejecutará continuamente hasta que el usuario lo solicite. Una vez que el proceso ha comenzado, me gustaría actualizar una de las variables locales dentro del proceso […]

Python múltiples hilos / múltiples procesos para leer puertos seriales

Estoy tratando de escribir una clase python utilizando procesamiento / subprocesos en paralelo para leer dos puertos seriales (/ dev / ttyS1 y / dev / ttyS2). Ambos puertos se ejecutan a una velocidad de 19200 baudios y están constantemente activos. Usé pySerial para este propósito. Ambas operaciones de lectura deben ejecutarse de forma continua […]

Python socket.gethostbyname_ex () multithread falla

Programé una secuencia de comandos que debería resolver varios nombres de host en direcciones IP utilizando Multithreading. Sin embargo, falla y se congela en algún punto aleatorio. ¿Cómo se puede resolver esto? num_threads = 100 conn = pymysql.connect(host=’xx.xx.xx.xx’, unix_socket=’/tmp/mysql.sock’, user=’user’, passwd=’pw’, db=’database’) cur = conn.cursor() def mexec(befehl): cur = conn.cursor() cur.execute(befehl) websites = [‘facebook.com’,’facebook.org’ … […]

Implementar un objeto de tipo spinner en una clase como un subproceso

Soy un principiante total y solo comencé a hacer clases hoy, y estoy tratando de hacer una especie de objeto ‘giratorio’ al que puedo llamar algo así: una de las cosas sobre las que estoy confundido es si usar ‘hilo’, ‘hilo’ o ‘procesos’. Acabo de leer en alguna parte que una instancia de un subproceso […]

Iterar sobre la lista de liderar y arrastrar con multiproceso

Quiero iterar sobre una lista con 2 funciones usando multiprocesamiento, una función iterar sobre main_list desde el principio y otra desde el final, quiero esta función cada vez que iterate sobre la lista de muestra ( g ) ponga el elemento en la lista principal hasta que uno de ellos encontrar un duplicado en la […]

¿Cómo se puede acceder a un puerto serie desde dos procesos diferentes (Python)?

Me gustaría usar el multiprocesamiento (para evitar problemas de GIL en máquinas con varios núcleos) y tener un proceso de lectura y un proceso de escritura utilizando el mismo puerto serie. ¿Es eso posible? Si es así, ¿cómo obtengo el puerto adquirido y luego cómo el niño procesa los objetos de archivo que pueden usar? […]

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 […]

Apio: ¿cómo limitar el número de tareas en la cola y dejar de alimentar cuando está lleno?

Soy muy nuevo en Celery y aquí está la pregunta que tengo: Supongamos que tengo un script que se supone que constantemente busca datos nuevos de la base de datos y los envía a los trabajadores usando Celery. tareas.py # Celery Task from celery import Celery app = Celery(‘tasks’, broker=’amqp://guest@localhost//’) @app.task def process_data(x): # Do […]