Cómo encontrar una identificación de hilo en Python

Tengo un programa Python de subprocesos múltiples y una función de utilidad writeLog(message)que escribe una marca de tiempo seguida del mensaje. Desafortunadamente, el archivo de registro resultante no indica qué hilo está generando qué mensaje.

Me gustaría writeLog()poder agregar algo al mensaje para identificar qué hilo lo está llamando. Obviamente, podría hacer que los hilos pasen esta información, pero eso sería mucho más trabajo. ¿Hay algún hilo equivalente al os.getpid()que podría usar?

threading.get_ident()funciona, o threading.current_thread().ident(o threading.currentThread().identpara Python <2.6).

Con el módulo de registro , puede agregar automáticamente el identificador de subproceso actual en cada entrada de registro. Solo use una de estas claves de mapeo LogRecord en su cadena de formato de registrador:

% (hilo) d: ID de hilo (si está disponible).

% (threadName) s: nombre del hilo (si está disponible).

y configure su controlador predeterminado con él:

logging.basicConfig(format="%(threadName)s:%(message)s")

La thread.get_ident()función devuelve un entero largo en Linux. No es realmente una identificación de hilo.

Utilizo este método para obtener realmente la identificación del hilo en Linux:

import ctypes
libc = ctypes.cdll.LoadLibrary('libc.so.6')

# System dependent, see e.g. /usr/include/x86_64-linux-gnu/asm/unistd_64.h
SYS_gettid = 186

def getThreadId():
   """Returns OS thread id - Specific to Linux"""
   return libc.syscall(SYS_gettid)

Esta funcionalidad ahora es compatible con Python 3.8+ :)

https://github.com/python/cpython/commit/4959c33d2555b89b494c678d99be81a65ee864b0

https://github.com/python/cpython/pull/11993

Vi ejemplos de ID de hilo como este:

class myThread(threading.Thread):
    def __init__(self, threadID, name, counter):
        self.threadID = threadID
        ...

La lista de documentos del módulo de subprocesosname también:

...

A thread has a name. 
The name can be passed to the constructor, 
and read or changed through the name attribute.

...

Thread.name

A string used for identification purposes only. 
It has no semantics. Multiple threads may
be given the same name. The initial name is set by the constructor.

Puede obtener la identificación del hilo actual en ejecución. El ident podría ser reutilizado para otros hilos, si el hilo actual termina.

Cuando crea una instancia de Thread, se le da un nombre implícito al thread, que es el patrón: Thread-number

El nombre no tiene significado y el nombre no tiene que ser único. La identificación de todos los hilos en ejecución es única.

import threading


def worker():
    print(threading.current_thread().name)
    print(threading.get_ident())


threading.Thread(target=worker).start()
threading.Thread(target=worker, name='foo').start()

La función threading.current_thread () devuelve el hilo actual en ejecución. Este objeto contiene toda la información del hilo.

Creé múltiples hilos en Python, imprimí los objetos de hilo e imprimí la identificación usando la identvariable. Veo que todos los identificadores son iguales:

<Thread(Thread-1, stopped 140500807628544)>
<Thread(Thread-2, started 140500807628544)>
<Thread(Thread-3, started 140500807628544)>

De manera similar a @brucexin, necesitaba obtener un identificador de subproceso a nivel del sistema operativo (que! = thread.get_ident()) Y usar algo como a continuación para no depender de números particulares y ser solo amd64:

---- 8< ---- (xos.pyx)
"""module xos complements standard module os""" 

cdef extern from "<sys/syscall.h>":                                                             
    long syscall(long number, ...)                                                              
    const int SYS_gettid                                                                        

# gettid returns current OS thread identifier.                                                  
def gettid():                                                                                   
    return syscall(SYS_gettid)                                                                  

y

---- 8< ---- (test.py)
import pyximport; pyximport.install()
import xos

...

print 'my tid: %d' % xos.gettid()

Sin embargo, esto depende de Cython.