Function _concurrent_submit

tests/test_concurrency.py:63–80

启动 n_threads 个线程，每线程提交 per_thread 次，返回 (results, errors)。

(engine, n_threads, per_thread)

def _concurrent_submit(engine, n_threads, per_thread):
    """启动 n_threads 个线程，每线程提交 per_thread 次，返回 (results, errors)。"""
    results = []
    errors = []
    # 使用屏障让所有线程尽可能同步启动
    barrier = threading.Barrier(n_threads)
    threads = [
        threading.Thread(
            target=_submit_n,
            args=(engine, per_thread, results, errors, barrier),
        )
        for _ in range(n_threads)
    ]
    for t in threads:
        t.start()
    for t in threads:
        t.join(timeout=30)
    return results, errors


# ---------------------------------------------------------------------------