Resultados de la búsqueda a petición "multiprocessing"
Multiprocesamiento Queue.get () se bloquea
Estoy tratando de implementar multiprocesamiento básico y me he encontrado con un problema. El script de Python se adjunta a continuación. import time, sys, random, threading from multiprocessing import Process from Queue import Queue from ...
Python ssl problema con multiprocesamiento
Quiero enviar datos desde un cliente al servidor en un socket TLS TCP desde múltiples subprocesos de cliente, por lo que comparto el mismo socket SSL con todos los subprocesos. La comunicación funciona con un subproceso, pero si uso más de un ...
Cómo hacer que todos los procesos pool.apply_async se detengan una vez que cualquier proceso haya encontrado una coincidencia en python
Tengo el siguiente código que aprovecha el multiprocesamiento para recorrer una lista grande y encontrar una coincidencia. ¿Cómo puedo hacer que todos los procesos se detengan una vez que se encuentra una coincidencia en cualquiera de los ...
Multiprocesamiento de Python: informe de progreso de procesos
Tengo algunas tareas en una aplicación que están vinculadas a la CPU y quiero usar el módulo de multiprocesamiento para usar los procesadores de núcleos múltiples. Tomo una gran tarea (un análisis de archivo de video) y la dividí en varias tareas ...
Manera fácil de usar opciones paralelas de funciones scikit-learn en HPC
En muchas funciones de scikit-learn se implementó una paralelización fácil de usar. Por ejemplo ensklearn.cross_validation.cross_val_score solo pasa el número deseado de trabajos computacionales enn_jobs argumento. Y para PC con ...
¿Qué sucede si inicio sesión en el mismo archivo desde varios procesos diferentes en Python?
Pasé horas investigando el comportamiento, primero sobre esas preguntas: Atomicidad de `write (2)` a un sistema de archivos local [https://stackoverflow.com/questions/10650861/atomicity-of-write2-to-a-local-filesystem] ¿Cómo puedo sincronizar, ...
Parámetro "chunksize" en el multiprocesamiento de Python.
Si tengo un objeto de grupo con 2 procesadores, por ejemplo: p=multiprocessing.Pool(2)y quiero iterar sobre una lista de archivos en el directorio y usar la función de mapa alguien podría explicar cuál es el tamaño de esta función: p.map(func, ...
Problemas de clasificación de imágenes en tiempo real de Python con redes neuronales
Intento usar caffe y python para hacer una clasificación de imágenes en tiempo real. Estoy usando OpenCV para transmitir desde mi cámara web en un proceso, y en un proceso separado, usando caffe para realizar la clasificación de imágenes en los ...
¿Por qué multiprocesamiento? El proceso se comporta de manera diferente en Windows y Linux para argumentos globales de objetos y funciones
El siguiente código tiene una salida diferente cuando se ejecuta en Windows y Linux (ambos con python2.7) '''import_mock.py''' to_mock = None '''test.py''' import import_mock from multiprocessing import Process class A(object): def ...
Pérdida de tiempo de execv () y fork ()
Actualmente estoy aprendiendo sobrefork() yexecv() y tenía una pregunta sobre la eficiencia de la combinación. Se me mostró el siguiente código estándar: pid = fork(); if(pid < 0){ //handle fork error } else if (pid == 0){ execv("son_prog", ...