cis-kuldeep/PyBitmessage-2021-04-27
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

Merge branch 'helper_threading_formating' of https://github.com/MahendraNG/PyBitmessage into helper_threading_formating

Browse Source
This commit is contained in:
Mahendra Garg 2018-04-10 13:25:37 +05:30
commit a836d0a9af
No known key found for this signature in database
GPG Key ID: A672D8FAAEE398B3
1 changed files with 12 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
src/helper_threading.py
View File

@ -1,9 +1,14 @@
"""Helper threading perform all the threading operations."""
from contextlib import contextmanager from contextlib import contextmanager
import threading import threading
try: try:
import prctl import prctl
def set_thread_name(name): prctl.set_name(name)
def set_thread_name(name):
"""Set a name for the thread for python internal use."""
prctl.set_name(name)
def _thread_name_hack(self): def _thread_name_hack(self):
set_thread_name(self.name) set_thread_name(self.name)
@ -12,7 +17,10 @@ try:
threading.Thread.__bootstrap_original__ = threading.Thread._Thread__bootstrap threading.Thread.__bootstrap_original__ = threading.Thread._Thread__bootstrap
threading.Thread._Thread__bootstrap = _thread_name_hack threading.Thread._Thread__bootstrap = _thread_name_hack
except ImportError: except ImportError:
def set_thread_name(name): threading.current_thread().name = name def set_thread_name(name):
"""Set the thread name for external use (visible from the OS)."""
threading.current_thread().name = name
class StoppableThread(object): class StoppableThread(object):
def initStop(self): def initStop(self):
@ -23,6 +31,7 @@ class StoppableThread(object):
self._stopped = True self._stopped = True
self.stop.set() self.stop.set()
class BusyError(threading.ThreadError): class BusyError(threading.ThreadError):
pass pass