1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
|
from pypy.interpreter.gateway import unwrap_spec
from pypy.interpreter.error import oefmt
def signals_enter(space):
space.threadlocals.enable_signals(space)
def signals_exit(space, w_ignored1=None, w_ignored2=None, w_ignored3=None):
space.threadlocals.disable_signals(space)
@unwrap_spec(tid=int)
def _raise_in_thread(space, tid, w_exc_type):
""" Raise exception of type exc_type the next time the thread with id tid
is resumed. Corresponds to the C-API PyThreadState_SetAsyncExc.
This is an experimental API, use with care."""
# w_exc_type can be None, but only when called from the actual
# PyThreadState_SetAsyncExc. in that case, the already scheduled
# w_async_exception_type is cancelled (of course it might or might not have
# been already delivered)
ecs = space.threadlocals.getallvalues()
for thread_ident, ec in ecs.items():
if thread_ident == tid:
ec.w_async_exception_type = w_exc_type
# make sure we switch away from the current thread soon, to give
# the target thread a chance to run
space.actionflag.rearm_ticker()
return
raise oefmt(space.w_ValueError, "couldn't find thread")
|
