`concurrent.futures.Executor.map` temporarily exceeds its `buffersize` while collecting the next result

Bug report

Bug description:

Potential follow up after the merge of #125663 (introduce buffersize param in Executor.map).

"Bug": concurrent.futures.Executor.map temporarily exceeds its buffersize while collecting the next result:

Let's define:

results: Iterator = executor.map(fn, iterable, buffersize=buffersize)

What happens when calling next(results):

1. fetch the next arg from interable and put a task for fn(arg) in the buffer
2. wait for next result to be available
3. yield the collected result

So during step 2. the buffer's size is actually buffersize + 1.

If we want a strict guarantee that there is at most buffersize concurrent tasks even during a next, we have to swap step 1. and step 2.

CPython versions tested on:

CPython main branch

Operating systems tested on:

No response

Linked PRs

• gh-131467

从 concurrent.futures.Executor.map 开始，检查围绕收集下一个结果所描述的行为。查看已链接的 PR gh-131467，以了解已经在进行的工作。完成的标准是确保在 next(results) 等待结果时，缓冲区绝不会暂时超过请求的 buffersize。