Resultados de la búsqueda a petición "pool"
¿Puedo usar una cola de multiprocesamiento en una función llamada por Pool.imap?
Estoy usando python 2.7 e intento ejecutar algunas tareas pesadas de la CPU en sus propios procesos. Me gustaría poder enviar mensajes de vuelta al proceso principal para mantenerlo informado sobre el estado actual del proceso. La cola de ...
Extraer datos de un CMSampleBuffer para crear una copia profunda
Estoy tratando de crear una copia de un CMSampleBuffer devuelto por captureOutput en un AVCaptureVideoDataOutputSampleBufferDelegate. Como los CMSampleBuffers provienen de un grupo preasignado de (15) buffers, si adjunto una referencia a ellos, ...
Python: cómo usar Value and Array en el grupo de multiprocesamiento
pormultiprocessing conProcess, Puedo usarValue, Array configurandoargs param. Conmultiprocessing conPool, como puedo usarValue, Array. No hay nada en los documentos sobre cómo hacer esto. from multiprocessing import Process, Value, Array def ...
Instanciación de cadenas de Java
¿Por qué este código devuelve "falso" en lugar de "verdadero": package com.company; public class Main { public static void main(String[] args) { String fullName = "Name Lastname"; String name = "Name "; String lastName = "Lastname"; String ...
No se puede encurtir la función
Así que estoy tratando de acelerar mi tiempo de cómputo haciendo un poco de multiprocesamiento Estoy tratando de usar a los trabajadores de la piscina. En la parte superior de mi código tengo import Singal as s import multiprocessing as mp def ...
Cómo dejar que Pool.map tome una función lambda
Tengo la siguiente función: def copy_file(source_file, target_dir): passAhora me gustaría usarmultiprocessing para ejecutar esta función de una vez: p = Pool(12) p.map(lambda x: copy_file(x,target_dir), file_list)El problema es que los lambda ...
Python NotImplementedError: los objetos de grupo no se pueden pasar entre procesos
Estoy tratando de entregar trabajo cuando una página se agrega a la lista de páginas, pero la salida de mi código devuelve un NotImplementedError. Aquí está el código con lo que estoy tratando de hacer: Código: from multiprocessing import Pool, ...
¿Cuál es la diferencia entre maxTotal y maxIdle en Apache Commons Pool 2?
Estoy usando la implementación Apache Commons Pool 2 para tener un mecanismo de grupo de objetos para mi aplicación. A partir de ahora, he establecido el valor predeterminado demaxTotal() ymaxIdle() como10 en mi código Pero no puedo entender ...
Multiprocesamiento de Python: seguimiento del proceso de la operación pool.map
Tengo una función que realiza una simulación y devuelve una matriz en formato de cadena. Quiero ejecutar la simulación (la función) para variar los valores de los parámetros de entrada, más de 10000 posibles valores de entrada y escribir ...
Forma correcta de implementar un grupo de recursos
Estoy tratando de implementar algo que administre un grupo de recursos de manera que el código de llamada pueda solicitar un objeto y se le otorgue uno del grupo si está disponible, o de lo contrario se hará esperar. Sin embargo, tengo problemas ...