Lines Matching refs:thread_group
64 thread_group = reraiser_thread.CurrentThreadGroup()
65 while thread_group:
66 if isinstance(thread_group, TimeoutRetryThreadGroup):
67 return thread_group
68 thread_group = thread_group.blocked_parent_thread_group
153 thread_group = TimeoutRetryThreadGroup(timeout, threads=[child_thread])
154 thread_group.StartAll(will_block=True)
156 thread_group.JoinAll(watcher=thread_group.GetWatcher(), timeout=60,
158 if thread_group.IsAlive():
161 return thread_group.GetAllReturnValues()[0]
