Jak znaleźć identyfikator wątku w Pythonie

Mam wielowątkowy program w Pythonie i funkcję narzędziową writeLog(message), która zapisuje znacznik czasu, po którym następuje komunikat. Niestety, wynikowy plik dziennika nie wskazuje, który wątek generuje dany komunikat.

Chciałbym writeLog()móc dodać coś do wiadomości, aby określić, który wątek ją wywołuje. Oczywiście mógłbym po prostu zmusić wątki do przekazywania tych informacji, ale wymagałoby to znacznie więcej pracy. Czy jest jakiś odpowiednik wątku os.getpid(), którego mógłbym użyć?

threading.get_ident()działa lub threading.current_thread().ident(lub threading.currentThread().identdla Pythona <2.6).

Korzystając z modułu rejestrowania , możesz automatycznie dodać bieżący identyfikator wątku do każdego wpisu dziennika. Po prostu użyj jednego z tych kluczy mapowania LogRecord w ciągu formatu loggera:

% (wątek) d: identyfikator wątku (jeśli jest dostępny).

% (threadName) s: nazwa wątku (jeśli jest dostępna).

i skonfiguruj z nim domyślną procedurę obsługi:

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

thread.get_ident()Zwraca długą liczbę całkowitą w systemie Linux. To naprawdę nie jest identyfikator wątku.

Używam tej metody, aby naprawdę uzyskać identyfikator wątku w systemie 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)

Ta funkcja jest teraz obsługiwana przez Python 3.8+ :)

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

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

Widziałem przykłady takich identyfikatorów wątków:

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

W docs modułu gwintowania listy nameatrybutów, a także:

...

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.

Możesz uzyskać identyfikator aktualnie działającego wątku. Identyfikator może zostać ponownie użyty dla innych wątków, jeśli bieżący wątek się zakończy.

Kiedy tworzysz wystąpienie Thread, wątkowi jest nadawana niejawna nazwa, która jest wzorcem: Numer-wątku

Nazwa nie ma znaczenia i nie musi być unikalna. Identyfikator wszystkich uruchomionych wątków jest unikalny.

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()

Funkcja threading.current_thread () zwraca bieżący wątek. Ten obiekt zawiera wszystkie informacje o wątku.

Utworzyłem wiele wątków w Pythonie, wydrukowałem obiekty wątków i wydrukowałem id za pomocą identzmiennej. Widzę, że wszystkie identyfikatory są takie same:

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

Podobnie jak w przypadku @brucexin, potrzebowałem uzyskać identyfikator wątku na poziomie systemu operacyjnego (który! = thread.get_ident()) I użyć czegoś takiego jak poniżej, aby nie polegać na konkretnych liczbach i być tylko 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)                                                                  

i

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

...

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

zależy to jednak od Cythona.