DR_Team/Difficult-Rocket
DR_Team/Difficult-Rocket
6
2
Fork 0
Code Issues Pull Requests Projects Releases 25 Wiki Activity

rue

Browse Source
This commit is contained in:
shenjack 2021-09-24 14:50:42 +08:00
parent 10e43428e5
commit 2cf2db3b21
1 changed files with 5 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
Difficult_Rocket/api/new_thread.py
View File

@ -3,17 +3,16 @@ import inspect
import threading import threading
import time import time
from typing import Optional, Callable from typing import Optional, Callable
from Difficult_Rocket.api import thread
from Difficult_Rocket import crash from Difficult_Rocket import crash
""" """
This part of code come from MCDReforged(https://github.com/Fallen_Breath/MCDReforged) This part of code come from MCDReforged(https://github.com/Fallen-Breath/MCDReforged)
Very thanks to Fallen_Breath and other coder who helped MCDR worked better Very thanks to Fallen_Breath and other coder who helped MCDR worked better
https://www.gnu.org/licenses/gpl-3.0.en.html GNU Lesser General Public License v3.0（GNU LGPL v3)
""" """
def new_thread(thread_name: Optional[str or Callable] = None): def new_thread(thread_name: Optional[str or Callable] = None, Daemon=False):
""" """
Use a new thread to execute the decorated function Use a new thread to execute the decorated function
The function return value will be set to the thread instance that executes this function The function return value will be set to the thread instance that executes this function
@ -24,9 +23,9 @@ def new_thread(thread_name: Optional[str or Callable] = None):
@functools.wraps(func) # to preserve the origin function information @functools.wraps(func) # to preserve the origin function information
def wrap(*args, **kwargs): def wrap(*args, **kwargs):
thread_ = threading.Thread(target=func, args=args, kwargs=kwargs, name=thread_name) thread_ = threading.Thread(target=func, args=args, kwargs=kwargs, name=thread_name)
thread_.setDaemon(False) thread_.setDaemon(Daemon)
thread_.start()
crash.all_thread.append(thread_) crash.all_thread.append(thread_)
thread_.start()
return thread return thread
# bring the signature of the func to the wrap function # bring the signature of the func to the wrap function