GH-100762: Don't call `gen.throw()` in `gen.close()`, unless necessary. (GH-101013)

* Store exception stack depth in YIELD_VALUE's oparg and use it avoid expensive gen.throw() in gen.close() where possible.
This commit is contained in:
Mark Shannon 2023-01-24 17:25:37 +00:00 committed by GitHub
parent daec3a463c
commit f02fa64bf2
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
9 changed files with 39 additions and 12 deletions

View File

@ -700,7 +700,10 @@ iterations of the loop.
Yields ``STACK.pop()`` from a :term:`generator`. Yields ``STACK.pop()`` from a :term:`generator`.
.. versionchanged:: 3.11 .. versionchanged:: 3.11
oparg set to be the stack depth, for efficient handling on frames. oparg set to be the stack depth.
.. versionchanged:: 3.12
oparg set to be the exception block depth, for efficient closing of generators.
.. opcode:: SETUP_ANNOTATIONS .. opcode:: SETUP_ANNOTATIONS

View File

@ -429,7 +429,8 @@ _code_type = type(_write_atomic.__code__)
# Python 3.12a1 3513 (Add CALL_INTRINSIC_1 instruction, removed STOPITERATION_ERROR, PRINT_EXPR, IMPORT_STAR) # Python 3.12a1 3513 (Add CALL_INTRINSIC_1 instruction, removed STOPITERATION_ERROR, PRINT_EXPR, IMPORT_STAR)
# Python 3.12a1 3514 (Remove ASYNC_GEN_WRAP, LIST_TO_TUPLE, and UNARY_POSITIVE) # Python 3.12a1 3514 (Remove ASYNC_GEN_WRAP, LIST_TO_TUPLE, and UNARY_POSITIVE)
# Python 3.12a1 3515 (Embed jump mask in COMPARE_OP oparg) # Python 3.12a1 3515 (Embed jump mask in COMPARE_OP oparg)
# Python 3.12a1 3516 (Add COMAPRE_AND_BRANCH instruction) # Python 3.12a1 3516 (Add COMPARE_AND_BRANCH instruction)
# Python 3.12a1 3517 (Change YIELD_VALUE oparg to exception block depth)
# Python 3.13 will start with 3550 # Python 3.13 will start with 3550
@ -442,7 +443,7 @@ _code_type = type(_write_atomic.__code__)
# Whenever MAGIC_NUMBER is changed, the ranges in the magic_values array # Whenever MAGIC_NUMBER is changed, the ranges in the magic_values array
# in PC/launcher.c must also be updated. # in PC/launcher.c must also be updated.
MAGIC_NUMBER = (3516).to_bytes(2, 'little') + b'\r\n' MAGIC_NUMBER = (3517).to_bytes(2, 'little') + b'\r\n'
_RAW_MAGIC_NUMBER = int.from_bytes(MAGIC_NUMBER, 'little') # For import.c _RAW_MAGIC_NUMBER = int.from_bytes(MAGIC_NUMBER, 'little') # For import.c

View File

@ -492,7 +492,7 @@ dis_asyncwith = """\
GET_AWAITABLE 1 GET_AWAITABLE 1
LOAD_CONST 0 (None) LOAD_CONST 0 (None)
>> SEND 3 (to 22) >> SEND 3 (to 22)
YIELD_VALUE 3 YIELD_VALUE 2
RESUME 3 RESUME 3
JUMP_BACKWARD_NO_INTERRUPT 4 (to 14) JUMP_BACKWARD_NO_INTERRUPT 4 (to 14)
>> POP_TOP >> POP_TOP
@ -526,7 +526,7 @@ dis_asyncwith = """\
GET_AWAITABLE 2 GET_AWAITABLE 2
LOAD_CONST 0 (None) LOAD_CONST 0 (None)
>> SEND 4 (to 92) >> SEND 4 (to 92)
YIELD_VALUE 6 YIELD_VALUE 3
RESUME 3 RESUME 3
JUMP_BACKWARD_NO_INTERRUPT 4 (to 82) JUMP_BACKWARD_NO_INTERRUPT 4 (to 82)
>> CLEANUP_THROW >> CLEANUP_THROW

View File

@ -0,0 +1,3 @@
Record the (virtual) exception block depth in the oparg of
:opcode:`YIELD_VALUE`. Use this to avoid the expensive ``throw()`` when
closing generators (and coroutines) that can be closed trivially.

View File

@ -354,6 +354,13 @@ gen_close(PyGenObject *gen, PyObject *args)
PyObject *yf = _PyGen_yf(gen); PyObject *yf = _PyGen_yf(gen);
int err = 0; int err = 0;
if (gen->gi_frame_state == FRAME_CREATED) {
gen->gi_frame_state = FRAME_COMPLETED;
Py_RETURN_NONE;
}
if (gen->gi_frame_state >= FRAME_COMPLETED) {
Py_RETURN_NONE;
}
if (yf) { if (yf) {
PyFrameState state = gen->gi_frame_state; PyFrameState state = gen->gi_frame_state;
gen->gi_frame_state = FRAME_EXECUTING; gen->gi_frame_state = FRAME_EXECUTING;
@ -361,8 +368,23 @@ gen_close(PyGenObject *gen, PyObject *args)
gen->gi_frame_state = state; gen->gi_frame_state = state;
Py_DECREF(yf); Py_DECREF(yf);
} }
if (err == 0) _PyInterpreterFrame *frame = (_PyInterpreterFrame *)gen->gi_iframe;
/* It is possible for the previous instruction to not be a
* YIELD_VALUE if the debugger has changed the lineno. */
if (err == 0 && frame->prev_instr->opcode == YIELD_VALUE) {
assert(frame->prev_instr[1].opcode == RESUME);
int exception_handler_depth = frame->prev_instr->oparg;
assert(exception_handler_depth > 0);
/* We can safely ignore the outermost try block
* as it automatically generated to handle
* StopIteration. */
if (exception_handler_depth == 1) {
Py_RETURN_NONE;
}
}
if (err == 0) {
PyErr_SetNone(PyExc_GeneratorExit); PyErr_SetNone(PyExc_GeneratorExit);
}
retval = gen_send_ex(gen, Py_None, 1, 1); retval = gen_send_ex(gen, Py_None, 1, 1);
if (retval) { if (retval) {
const char *msg = "generator ignored GeneratorExit"; const char *msg = "generator ignored GeneratorExit";

View File

@ -720,7 +720,6 @@ dummy_func(
// NOTE: It's important that YIELD_VALUE never raises an exception! // NOTE: It's important that YIELD_VALUE never raises an exception!
// The compiler treats any exception raised here as a failed close() // The compiler treats any exception raised here as a failed close()
// or throw() call. // or throw() call.
assert(oparg == STACK_LEVEL());
assert(frame != &entry_frame); assert(frame != &entry_frame);
PyGenObject *gen = _PyFrame_GetGenerator(frame); PyGenObject *gen = _PyFrame_GetGenerator(frame);
gen->gi_frame_state = FRAME_SUSPENDED; gen->gi_frame_state = FRAME_SUSPENDED;

View File

@ -7162,9 +7162,6 @@ stackdepth(basicblock *entryblock, int code_flags)
next = NULL; next = NULL;
break; break;
} }
if (instr->i_opcode == YIELD_VALUE) {
instr->i_oparg = depth;
}
} }
if (next != NULL) { if (next != NULL) {
assert(BB_HAS_FALLTHROUGH(b)); assert(BB_HAS_FALLTHROUGH(b));
@ -7332,6 +7329,9 @@ label_exception_targets(basicblock *entryblock) {
} }
} }
else { else {
if (instr->i_opcode == YIELD_VALUE) {
instr->i_oparg = except_stack->depth;
}
instr->i_except = handler; instr->i_except = handler;
} }
} }

View File

@ -919,7 +919,6 @@
// NOTE: It's important that YIELD_VALUE never raises an exception! // NOTE: It's important that YIELD_VALUE never raises an exception!
// The compiler treats any exception raised here as a failed close() // The compiler treats any exception raised here as a failed close()
// or throw() call. // or throw() call.
assert(oparg == STACK_LEVEL());
assert(frame != &entry_frame); assert(frame != &entry_frame);
PyGenObject *gen = _PyFrame_GetGenerator(frame); PyGenObject *gen = _PyFrame_GetGenerator(frame);
gen->gi_frame_state = FRAME_SUSPENDED; gen->gi_frame_state = FRAME_SUSPENDED;

View File

@ -59,7 +59,7 @@ static const struct {
[GET_ANEXT] = { 1, 2, DIR_NONE, DIR_NONE, DIR_NONE, true, INSTR_FMT_IX }, [GET_ANEXT] = { 1, 2, DIR_NONE, DIR_NONE, DIR_NONE, true, INSTR_FMT_IX },
[GET_AWAITABLE] = { 1, 1, DIR_NONE, DIR_NONE, DIR_NONE, true, INSTR_FMT_IB }, [GET_AWAITABLE] = { 1, 1, DIR_NONE, DIR_NONE, DIR_NONE, true, INSTR_FMT_IB },
[SEND] = { -1, -1, DIR_NONE, DIR_NONE, DIR_NONE, true, INSTR_FMT_IB }, [SEND] = { -1, -1, DIR_NONE, DIR_NONE, DIR_NONE, true, INSTR_FMT_IB },
[YIELD_VALUE] = { 1, 1, DIR_NONE, DIR_NONE, DIR_NONE, true, INSTR_FMT_IB }, [YIELD_VALUE] = { 1, 1, DIR_NONE, DIR_NONE, DIR_NONE, true, INSTR_FMT_IX },
[POP_EXCEPT] = { 1, 0, DIR_NONE, DIR_NONE, DIR_NONE, true, INSTR_FMT_IX }, [POP_EXCEPT] = { 1, 0, DIR_NONE, DIR_NONE, DIR_NONE, true, INSTR_FMT_IX },
[RERAISE] = { -1, -1, DIR_NONE, DIR_NONE, DIR_NONE, true, INSTR_FMT_IB }, [RERAISE] = { -1, -1, DIR_NONE, DIR_NONE, DIR_NONE, true, INSTR_FMT_IB },
[PREP_RERAISE_STAR] = { 2, 1, DIR_NONE, DIR_NONE, DIR_NONE, true, INSTR_FMT_IX }, [PREP_RERAISE_STAR] = { 2, 1, DIR_NONE, DIR_NONE, DIR_NONE, true, INSTR_FMT_IX },