@@ -44,7 +44,7 @@ class Thread(threading.Thread, Generic[_Target_P, _Target_T]):
4444
4545 status : ThreadStatus
4646 hooks : List [HookFunction ]
47- returned_value : Data_Out
47+ _returned_value : Data_Out
4848
4949 errors : List [Exception ]
5050 ignore_errors : Sequence [type [Exception ]]
@@ -86,7 +86,7 @@ def __init__(
8686 :param **: These are arguments parsed to `thread.Thread`
8787 """
8888 _target = self ._wrap_target (target )
89- self .returned_value = None
89+ self ._returned_value = None
9090 self .status = 'Idle'
9191 self .hooks = []
9292
@@ -116,7 +116,7 @@ def wrapper(*args: _Target_P.args, **kwargs: _Target_P.kwargs) -> Union[_Target_
116116 Threads .add (self )
117117
118118 try :
119- self .returned_value = target (* args , ** kwargs )
119+ self ._returned_value = target (* args , ** kwargs )
120120 except Exception as e :
121121 if not any (isinstance (e , ignore ) for ignore in self .ignore_errors ):
122122 self .status = 'Errored'
@@ -135,7 +135,7 @@ def _invoke_hooks(self) -> None:
135135 errors : List [Tuple [Exception , str ]] = []
136136 for hook in self .hooks :
137137 try :
138- hook (self .returned_value )
138+ hook (self ._returned_value )
139139 except Exception as e :
140140 if not any (isinstance (e , ignore ) for ignore in self .ignore_errors ):
141141 errors .append ((
@@ -196,7 +196,7 @@ def result(self) -> _Target_T:
196196
197197 self ._handle_exceptions ()
198198 if self .status in ['Invoking hooks' , 'Completed' ]:
199- return self .returned_value
199+ return self ._returned_value
200200 else :
201201 raise exceptions .ThreadStillRunningError ()
202202
0 commit comments