github/nohang
2
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Use threading to speed up GUI notifications

Browse Source
This commit is contained in:
Alexey Avramov 2019-09-15 19:08:50 +09:00
parent 5242ed10e3
commit 05ae755415
1 changed files with 22 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

25
nohang
View File

@ -9,6 +9,7 @@ from sys import stdout, stderr, argv, exit
from re import search from re import search
from sre_constants import error as invalid_re from sre_constants import error as invalid_re
from signal import signal, SIGKILL, SIGTERM, SIGINT, SIGQUIT, SIGHUP from signal import signal, SIGKILL, SIGTERM, SIGINT, SIGQUIT, SIGHUP
from threading import Thread
########################################################################## ##########################################################################
@ -291,6 +292,7 @@ def signal_handler_inner(signum, frame):
def exe(cmd): def exe(cmd):
""" """
""" """
log('Execute the command: {}'.format(cmd)) log('Execute the command: {}'.format(cmd))
t0 = time() t0 = time()
write_self_oom_score_adj(self_oom_score_adj_max) write_self_oom_score_adj(self_oom_score_adj_max)
@ -301,6 +303,21 @@ def exe(cmd):
return err return err
def go (func, *a):
""" run func in new thread
"""
t1 = time()
try:
Thread(target=func, args=a).start()
except RuntimeError:
print('RuntimeError: cannot spawn a new thread')
t2 = time()
log('New thread spawned in {} ms'.format(
round((t2 - t1) * 1000, 1)
))
def write(path, string): def write(path, string):
""" """
""" """
@ -1071,7 +1088,7 @@ def send_notification(title, body):
title, title,
encoder(body)) encoder(body))
exe(cmd) go(exe, cmd)
def get_pid_list(): def get_pid_list():
@ -1933,7 +1950,7 @@ def implement_corrective_action(
cmd = command.replace('$PID', pid).replace('$NAME', pid_to_name( cmd = command.replace('$PID', pid).replace('$NAME', pid_to_name(
pid)).replace('$SERVICE', service) pid)).replace('$SERVICE', service)
exit_status = exe(cmd) go(exe, cmd)
""" """
if exit_status == 0: if exit_status == 0:
@ -1946,6 +1963,8 @@ def implement_corrective_action(
response_time = time() - time0 response_time = time() - time0
exit_status = None
preventing_oom_message = 'Implement a corrective act' \ preventing_oom_message = 'Implement a corrective act' \
'ion:\n Run the command: {}' \ 'ion:\n Run the command: {}' \
'\n Exit status: {}; total response ' \ '\n Exit status: {}; total response ' \
@ -2084,7 +2103,7 @@ def implement_corrective_action(
log('Execute post_kill_exe') log('Execute post_kill_exe')
exe(cmd) go(exe, cmd)
if post_action_gui_notifications: if post_action_gui_notifications:
if soft_match: if soft_match: