Articles of multithreading

¿Cuál es el patrón de uso recomendado de scoped_session en una aplicación web sqlalchemy multiproceso?

Estoy escribiendo una aplicación con python y sqlalchemy-0.7. Comienza iniciando el sqlalchemy orm (usando declarativo) y luego inicia un servidor web multiproceso. Actualmente estoy usando web.py para la creación rápida de prototipos, pero eso podría cambiar en el futuro. También agregaré otros “subprocesos” para trabajos progtwigdos, etc., probablemente utilizando otros subprocesos de Python. De la […]

SQLAlchemy manejo adecuado de sesión en aplicaciones multi-hilo

Tengo problemas para entender cómo abrir y cerrar las sesiones de la base de datos de manera eficiente, como entendí en la documentación de sqlalchemy, si uso scoped_session para construir mi objeto Session y luego el objeto Session devuelto para crear sesiones, es seguro para subprocesos, así que básicamente cada hilo. obtendrá su propia sesión, […]

¿Es posible leer marcos de webcam en paralelo?

Tengo un simple script de Python que captura una cámara web utilizando OpenCV . Mi cámara web tiene el potencial de transmitir 30 FPS, pero como mi Raspberry Pi no es lo suficientemente potente, solo puedo leer ~ 20 FPS. Al ejecutar el script, un núcleo de mi CPU tiene un máximo de 100%, pero […]

Sincronizando múltiples hilos en python

Tengo un problema en el que necesito x subprocesos para esperar hasta que todos hayan alcanzado un punto de sincronización. Mi solución utiliza el siguiente método de synchronise , que cada función de subproceso llama cuando necesitan sincronizarse. ¿Hay una mejor manera de hacer esto? thread_count = 0 semaphore = threading.Semaphore() event = threading.Event() def […]

¿Cómo puedo bloquear una conexión SQLite completa (lectura bloqueada + escritura bloqueada)?

Tengo un db sqlite3 que se está accediendo al mismo tiempo. Tengo ClientA que lee el estado de alguna tabla (la Columna 1 tiene las filas A , B , C ) y necesita actualizar la tabla con las nuevas letras del alfabeto. Si ClientB lee el estado de la tabla antes de que ClientA […]

Problema de rendimiento en python con bucle nested

Pude mejorar mucho un código escrito en python con numpy debido al producto punto. Ahora todavía tengo una parte del código que todavía es muy lenta. Todavía no entiendo multiproceso y si esto podría ayudar aquí. En mi opinión, esto debería ser posible aquí. ¿Tienes una buena idea de qué hacer aquí? for x1 in […]

¿Entiendes este punto muerto?

Estoy usando wxPython para mi GUI. En la clase AppLogic tengo un subproceso de trabajo que se ejecuta en un método de esta misma clase. Esta es la clase GUI : class GUI: _wx_app = None _main_window = None _app_logic = None def start(self): # bla bla bla self._main_window.Show() self._app_logic.begin() self._wx_app.MainLoop() def _cancel_listener(self): “””Called from […]

Mejorar la velocidad de las secuencias de comandos de Python: subprocesos múltiples o instancias múltiples?

Tengo una secuencia de comandos de Python que me gustaría ejecutar todos los días y prefiero que solo tarde de 1 a 2 horas en ejecutarse. Actualmente está configurado para alcanzar 4 API diferentes para una URL determinada, capturar los resultados y luego guardar los datos en una base de datos PostgreSQL. El problema es […]

¿Cómo se comparten las variables entre las llamadas `session.run (…)` concurrentes en tensorflow?

Si realiza dos llamadas simultáneas a la misma sesión, sess.run(…) , ¿cómo se accede simultáneamente a las variables en tensorflow? ¿Verá cada llamada una instantánea de las variables a partir del momento en que se run la run , consistente a lo largo de la llamada? ¿O verán actualizaciones dinámicas de las variables y solo […]

La función join () en threading.

Así que recientemente traté de entender la función join (), pero parece que la cantidad de tutoriales / documentaciones que leo no lo entiendo. ¿Hay alguien aquí que sea capaz de explicármelo?