May 6, 2023 · May 3, 2023 · May 3, 2023 · May 4, 2023 · May 5, 2023 · May 5, 2023
diff --git a/Lib/asyncio/tasks.py b/Lib/asyncio/tasks.py
    children = []
    nfuts = 0
    nfinished = 0
    done_futs = []
    loop = None
    outer = None  # bpo-46672
    all_finished = True
    for arg in coros_or_futures:
        if arg not in arg_to_fut:
            fut = ensure_future(arg, loop=loop)
            nfuts += 1
            arg_to_fut[arg] = fut
            if fut.done():
                # call the callback immediately instead of scheduling it
                _done_callback(fut)
                done_futs.append(fut)
            else:
                all_finished = False
                fut.add_done_callback(_done_callback)

        else:

        children.append(fut)

    if all_finished:
        # optimization: skip creating GatheringFuture if all children completed
        # (e.g. when all coros are able to complete eagerly)
        outer = futures.Future(loop=loop)
        outer.set_result([c.result for c in children])
    else:
        outer = _GatheringFuture(children, loop=loop)
    outer = _GatheringFuture(children, loop=loop)
    # call the done callbacks for futures that finished eagerly, instead
    # of scheduling the callbacks to be called later by the event loop
    # optimization: in the special case that *all* futures finished eagerly,
    # this will effectively complete the gather eagerly, with the last
    # callback setting the result (or exception) on outer before returning it
    for fut in done_futs:
        _done_callback(fut)
    return outer
Original file line number	Diff line number	Diff line change
Expand Up		@@ -813,9 +813,9 @@ def _done_callback(fut):
		children = []
		nfuts = 0
		nfinished = 0
		done_futs = []
		loop = None
		outer = None # bpo-46672
		all_finished = True
		for arg in coros_or_futures:
		if arg not in arg_to_fut:
		fut = ensure_future(arg, loop=loop)
Expand All		@@ -831,10 +831,8 @@ def _done_callback(fut):
		nfuts += 1
		arg_to_fut[arg] = fut
		if fut.done():
		# call the callback immediately instead of scheduling it
		_done_callback(fut)
		done_futs.append(fut)
		else:
		all_finished = False
		fut.add_done_callback(_done_callback)

		else:
Expand All		@@ -843,13 +841,14 @@ def _done_callback(fut):

		children.append(fut)

		if all_finished:
		# optimization: skip creating GatheringFuture if all children completed
		# (e.g. when all coros are able to complete eagerly)
		outer = futures.Future(loop=loop)
		outer.set_result([c.result for c in children])
		else:
		outer = _GatheringFuture(children, loop=loop)
		outer = _GatheringFuture(children, loop=loop)
		# call the done callbacks for futures that finished eagerly, instead
		# of scheduling the callbacks to be called later by the event loop
		# optimization: in the special case that all futures finished eagerly,
		# this will effectively complete the gather eagerly, with the last
		# callback setting the result (or exception) on outer before returning it
		for fut in done_futs:
		_done_callback(fut)
		return outer


Expand Down