问为什么我总是让GetOverlappedResult得到错误的109号

EN

    mgr = MP.Manager()
    mp_dataset = mgr.dict(dataset)
    mp_seen = mgr.dict({k: None for k in seen})
    mp_barrier = MP.Barrier(WORKER_COUNT + 1)  # +1 to include main process

    # TileQueue is a global var
    workers = [
        MP.Process(target=process_item_worker, args=(TileQueue, mp_dataset, mp_seen, mp_barrier))
        for _ in range(0, WORKER_COUNT)
    ]
    [worker.start() for worker in workers]
    print("Waiting for workers...")
    mp_barrier.wait()

    start_t = time.monotonic()
    try:
        asyncio.run(fetch_more_data())
        elapsed_t = time.monotonic() - start_t
        print(f"\nFetching finished in {elapsed_t:,.2f} seconds", flush=True)
    except Exception as e:
        print(f"\nAn Exception happened: {e}")
    finally:
        # Save the results first, convert from managed to normal dicts
        dataset.update(mp_dataset)
        progress["seen"] = dict(mp_seen)
        with PROGRESS_FILE.open("wb") as fout:
            pickle.dump(progress, fout)
        # Then we tell workers to disband
        [TileQueue.put(None) for _ in workers]
        print("Waiting for workers...", flush=True)
        for w in workers:
            w.join()
        TileQueue.close()

    print("Start processing updated dataset")