Articles of multiproceso de

¿Cuál es una forma segura de “enlazar” la variable de entorno en python?

Supongamos que tenemos una biblioteca A comportamiento de A bruja depende del valor de alguna variable de entorno. A_CONFIG_PATH realidad. Algunas de mis tareas usan esta biblioteca con diferentes A_CONFIG_PATH para cada tarea. Lo hago de una manera de import os import A def task(**kw): os.environ[‘A_CONFIG_PATH’] = ‘/home/me/current/task/config/path’ A.do_some_stuff(kw) Esta multa hasta que todas las […]

multihilo: ¿Por qué los generadores no son seguros para subprocesos? ¿Qué pasa cuando se comparte entre hilos?

Estoy leyendo esta pregunta que pregunta si los generadores son seguros para subprocesos, y una respuesta dijo: No es seguro para subprocesos; Las llamadas simultáneas pueden intercalarse y desordenarse con las variables locales. Otra respuesta muestra que puede usar un locking para asegurarse de que solo un hilo use el generador a la vez. Soy […]

¿Cómo depurar el punto muerto con python?

Estoy desarrollando una aplicación de subprocesos múltiples, que está en un punto muerto. Estoy usando Visual C ++ Express 2008 para rastrear el progtwig. Una vez que se produce el punto muerto, simplemente detengo el progtwig y rastro. Descubrí que cuando se produce un interlocking, habrá dos subprocesos llamados python desde mi extensión C ++. […]

Dos clientes no se conectan con éxito al servidor

Quiero agregar una función donde dos clientes pueden enviarse mensajes sin parar y sin necesidad de esperar. Tengo un script del servidor: import socket import threading from datetime import datetime from random import randint global num num = 0 class serverThread(threading.Thread): def __init__(self, client, address): global num num = num + 1 self.id = num […]

Hilo de matar Python

Estoy tratando de matar un hilo en python. Una excepción sería la forma preferida de hacerlo, ya que una salida elegante del método de ejecución del hilo a través de un bash: excepto: el par permitiría cerrar recursos. Lo intenté: ¿hay alguna forma de matar un hilo en Python? , pero especifica que no funciona […]

El subproceso se completa pero aún no finaliza, lo que provoca un interlocking

Ok, ya que actualmente no hay respuesta, no me siento tan mal haciendo esto. Si bien todavía estoy interesado en lo que realmente está sucediendo detrás de escena para causar este problema, mis preguntas más urgentes son las que se especifican en la actualización 2. Esas son, ¿Cuáles son las diferencias entre JoinableQueue y Manager().Queue() […]

¿Por qué la comunicación a través de la memoria compartida es mucho más lenta que a través de las colas?

Estoy usando Python 2.7.5 en un Apple MacBook Pro de cosecha reciente que tiene cuatro hardware y ocho CPU lógicas; Es decir, la utilidad sysctl da: $ sysctl hw.physicalcpu hw.physicalcpu: 4 $ sysctl hw.logicalcpu hw.logicalcpu: 8 Necesito realizar un procesamiento bastante complicado en una gran lista o matriz 1-D, y luego guardar el resultado como […]

Código de salida de hilo de Python

¿Hay una manera de saber si un hilo ha salido normalmente o debido a una excepción?

Tiempo de espera de Python

He estado buscando por todas partes un buen script de tiempo de espera que puede matar un hilo si ha estado activo durante más de X segundos, pero todos los ejemplos que he visto tienen fallas que no siempre lo detienen. Usando thread.join (x) termina venciendo el propósito de ser un hilo. El único ejemplo […]

Python ThreadPoolExecutor: ¿se garantiza que la callback se ejecute en el mismo hilo que la función enviada?

En el ThreadPoolExecutor (TPE), ¿se garantiza que la callback siempre se ejecute en el mismo hilo que la función enviada? Por ejemplo, he probado esto con el siguiente código. Lo ejecuté muchas veces y parecía que func y callback siempre se ejecutaban en el mismo hilo. import concurrent.futures import random import threading import time executor […]