Skip to content

ProcessPoolExecutor.map may hang forever when the submitted iterable is far greater than max_tasks_per_child #111498

Closed as duplicate

Description

@alirzaev

Bug report

Bug description:

Summary

ProcessPoolExecutor.map may hang forever when the submitted iterable is far greater than max_tasks_per_child

Internally ProcessPoolExecutor.map submits to the executor all items from the iterable (via submit). The worker process exits when the first max_tasks_per_child work items are processed but a new worker process isn't created because ProcessPoolExecutor._adjust_process_count can be invoked only in submit

Reproducible example

import time
from concurrent.futures import ProcessPoolExecutor


def work(i):
    time.sleep(1)

    return i * i


def main():
    with ProcessPoolExecutor(max_workers=1) as executor:
        _ = list(executor.map(work, range(100)))
        # completes

    with ProcessPoolExecutor(max_workers=1, max_tasks_per_child=5) as executor:
        _ = list(executor.map(work, range(100)))
        # hangs forever


if __name__ == '__main__':
    main()

Expected behavior

Program exits

Actual behavor

Program hangs forever

CPython versions tested on:

3.11

Operating systems tested on:

Windows

Activity

  1. added
    stdlibStandard Library Python modules in the Lib/ directory
    on Nov 26, 2023
  2. cwindolf commented on Feb 1, 2024

    @cwindolf

    I'm observing the same issue (using the same test case, with some added prints to make sure the first map completes) on Python 3.11.4 and Python 3.12.1 on Linux as well. Using range(10) is enough to see the issue. By adding print(f"work {i=}") inside the work function, I can observe that the second map only makes it to i=4, indicating that only one child process was created.

    In other words, the test case:

    import time
    from concurrent.futures import ProcessPoolExecutor
    
    
    def work(i):
        print(f"work {i=}", flush=True)
        time.sleep(1)
        return i * i
    
    
    def main():
        print("main")
        with ProcessPoolExecutor(max_workers=1) as executor:
            print("start A", flush=True)
            _ = list(executor.map(work, range(10)))
            # completes
        print("done A", flush=True)
    
        with ProcessPoolExecutor(max_workers=1, max_tasks_per_child=5) as executor:
            print("start B", flush=True)
            _ = list(executor.map(work, range(10)))
            # hangs forever
        print("done B", flush=True)
    
    
    if __name__ == '__main__':
        main()
    

    produces the output

    $ python test.py
    main
    start A
    work i=0
    work i=1
    work i=2
    work i=3
    work i=4
    work i=5
    work i=6
    work i=7
    work i=8
    work i=9
    done A
    start B
    work i=0
    work i=1
    work i=2
    work i=3
    work i=4
    

    and hangs.

  3. gpshead commented on Jul 3, 2026

    @gpshead
    Member

    Confirmed fixed by GH-140900. Same root cause, map() manifestation. Reproducer hangs on unpatched main (killed at 60s), completes in ~1s with the fix.

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Metadata

Metadata

Assignees

No one assigned

    Labels

    stdlibStandard Library Python modules in the Lib/ directorytype-bugAn unexpected behavior, bug, or error

    Projects

    No projects

      Milestone

      No milestone

      Relationships

      None yet

      Development

      No branches or pull requests

      Issue actions